Rxjs执行处理器只有一次

Question

我有两个观察到的，我听着也与合并操作时，其中一个是火，或两者我只需要执行一次处理，我怎么能做到这一点与RX？

var source1 = Rx.Observable.interval(1000); 

var source2 = Rx.Observable.interval(1000); 

var source = Rx.Observable.merge(
    source1, 
    source2) 
    .subscribe(() => console.log('This needs to run only once and not kill the stream')) 

Answer 1

您可以使用多播

可选的选择功能，可以使用多播源流作为根据需要多次选择功能，而不会造成多次预订源流。给定来源的订阅者将从订阅期间收到所有来源的通知。

http://reactivex.io/rxjs/class/es6/Observable.js~Observable.html#instance-method-multicast

function factory() { 
    return new Rx.Subject(); 
} 

source.multicast(factory, function(shared) { 
    return shared.take(1).do(x=>console.log(x)).concat(shared); 
}) 
.subscribe();