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 同时是观察者和可观察者。因此，您可以订阅 to/from 个主题。

rxjs 中 Bacon.Bus.plug 的等价物是什么

What is the equivalint of Bacon.Bus.plug in rxjs

rxjs

bacon.js