Concat Array of Observables 并具有单个订阅输出

Question

我的软件中有几个案例，其中我有一组可观察对象，我需要按顺序执行它们。只有在上一个订阅完成后才会进行下一个订阅。

所以我使用concat 运算符。它工作得很好，但是每次Observables 之一完成时都会触发它的订阅，我需要只有在一切完成后才触发它。

concat(
  of(1, 2, 3).pipe(delay(3000)),
  // after 3s, the first observable will complete and subsquent observable subscribed with values emitted
  of(4, 5, 6).pipe(delay(3000)),
)
  // log: 1,2,3,4,5,6
  .subscribe((v) => {
  // Needs to be triggered once after everything is complete
    console.log(v);
  });

我需要一种方法来管道这个 observable，这样订阅只会在一切完成后触发一次，在这种情况下，订阅的值并不重要，因此可以省略。

如果可能，这些值可以在订阅上下文中以数组的形式提供。

Answer 1

使用toArray 收集数组中的值。

import { toArray } from 'rxjs/operators';

concat(
  of(1, 2, 3).pipe(delay(3000)),
  of(4, 5, 6).pipe(delay(3000)),
).pipe(
  toArray()
).subscribe(v => console.log(v)); // log: [1,2,3,4,5,6]

或者，如果您不需要响应，请使用 @Willem 解决方案中的 complete 回调。

Answer 2

将结果输入finalize():

当 observable 完成或出错时调用函数

见https://www.learnrxjs.io/operators/utility/finalize.html

订阅complete事件：

.subscribe({
  complete: () => { ... }
})

使用forkJoin()，特别是如果您想要最终值：

当所有 observables 完成后，发出每个 observables 最后发出的值。

https://www.learnrxjs.io/operators/combination/forkjoin.html