合并 Observable 并在所有主体都发出值时采取行动

Question

我想将可观察对象合并为一个，然后在所有主题都发出值时订阅。到目前为止，我已经尝试过 Observable.merge 和 Observable.zip

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

但如果我在上面这样做，我认为订阅者会听到 A、B、C 或 D 主题中的任何一个来发出一个值，而不是全部。 什么方法可以等到 A、B、C 和 D 都发出一个值？

Answer 1

您可以使用Observable.forkJoin，它会等待所有源 Observable 发出至少一个值并且它们都完成。但由于您使用的是主题，它们很可能没有完成，因此使用 .zip() 是有意义的。

zip() 运算符仅在所有源发出 X 值时才会发出 Xth。在您的情况下，zip() 只会在所有 A、B、C 和 D 发出至少一个项目时发出一个项目。

但是，如果您使用 merge，它会在每次 A、B、C 和 D 发出一个项目时发出。

现场演示：http://jsbin.com/hihutoj/8/edit?js,output