Observableをマージして、すべてのサブジェクトが値を発行したときに処理を実行します。

Question

オブザーバブルを1つにマージし、すべてのサブジェクトが値を発行したときにサブスクライブしたいとします。これまでのところ、私は

public A:Subject<any> = new Subject(); 
public B:Subject<any> = new Subject(); 
public C:Subject<any> = new Subject(); 
public D:Subject<any> = new Subject(); 
public Complete:Subject<any> = new Subject(); 

A.next(true); 
B.next(true); 
C.next(true); 
D.next(true); 

Observable.zip(A,B,C,D).subscribe(res=>{Complete.next(true)}) 

Observable.mergeとObservable.zip

を試みた。しかし、私は上記行う場合、私は、加入者がいない、値を発するようにA、B、CまたはDの件名のいずれかに耳を傾けるだろうと思いますすべて。 A、B、C、Dがすべて値を出力するまで待つ方法は何でしょうか？

Answer 1

Observable.forkJoinは、すべてのソースオブザーバブルが少なくとも1つの値を出力し、それらのすべてが完了するまで待機します。しかし、あなたは科目を使っているので、完了しない可能性が非常に高いです。.zip()を使うと意味があります。

zip()オペレータは、すべてのソースがXの値を放出した場合にのみ、Xを送信します。あなたの場合、zip()は、すべてA,B,CおよびDが少なくとも1つのアイテムを放出する場合にのみ単一のアイテムを放出します。

あなたがmergeを使用している場合しかし、それはA、B、CとDのいずれかの項目を発するたびに放出します。

ライブデモ：可能であればhttp://jsbin.com/hihutoj/8/edit?js,output