Rxjsは一度だけハンドラを実行します

Question

私はマージ演算子で1つが火災したときにリッスンしているか、両方ともハンドラを1回だけ実行する必要があることを2つ観測できます。

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