在rxjs中Bacon.Bus.plug的等效性是什么？

Question

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

在培根中，我可以很容易地用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同时是一个观察者和一个可观察的。所以，你可以订阅一个主题。