rxjs - rxjs 中的 Bacon.Bus.plug 相当于什么

Question

是否可以将 Observable 插入到 rxjs Subject 中？

在 Bacon 中，我可以使用 plug 方法轻松插入新流，但在 rxjs 中我还没有找到单行代码。所以现在我这样做:

var subject = new Rx.Subject();
var clickStream = new Rx.Observable.fromEvent(button, 'click');
clickStream.subscribe(function(e){
  subject.onNext(e);
});

我无法使用merge，因为我稍后渲染此按钮。我希望存在这样的方法:

subject.plug(clickStream);

谢谢 B.

Answer 1

你想做的是:

var subject = new Rx.Subject();
var clickStream = Rx.Observable.fromEvent(button, 'click');

clickStream.subscribe(subject);

您不需要传递调用 subject.onNext 的函数，因为 Rx.Subject 同时是观察者和可观察者。因此，您可以订阅某个主题/从某个主题订阅主题。