Что такое эквивалент Bacon.Bus.plug in rxjs

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); 

Благодаря Б.

Answer 1

То, что вы хотите сделать, это:

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

clickStream.subscribe(subject); 

Вам не нужно передать функции, которые называют subject.onNext потому что Rx.Subject является, в то же время, наблюдателем и наблюдаемым. Таким образом, вы можете подписаться на/из темы.