RxJS:完成时与单个发射合并

Question

是否有 RxJS 工厂函数(或更普遍的模式)将多个其他函数合并在一起，但仅在所有函数完成时发出一次？

我想要这个的用例是等待几个并行操作，然后在它们完成后做其他事情。对于 promise ，这​​可以像这样完成:

Promise.all(A, B, C).then(() => console.log('done'));

对于 observables，我想到的最好的是

merge(A, B, C).pipe(takeLatest(1)).subscribe(() => console.log('done'));

不过，这并未说明 A、B 和 C 为空。而且它不会为订户提供确定性的值(value)。没有针对此用例的简单内置解决方案吗？

Answer 1

您可以使用 forkJoin .一旦所有给定的可观察对象完成，此运算符就会发出。

const { Observable, of, forkJoin } = rxjs;

const obs1$ = new Observable(subscriber => {
  subscriber.next('obs1$ - value 1');
  subscriber.next('obs1$ - value 2');
  subscriber.complete();
})
const obs2$ = of('obs2$');
const obs3$ = of('obs3$');

const result$ = forkJoin(
  obs1$,
  obs2$,
  obs3$
);

result$.subscribe(v => console.log(v));

<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/6.5.3/rxjs.umd.min.js"></script>