RxJs forkJoin：当所有可观察对象都出错或成功时执行

Question

假设我有以下代码，其中一个 observable 抛出错误，另一个在延迟后成功：

let observables: Observable<String>[] = [
  of("string 1").pipe(delay(1000)),
  throwError("error")
];

observables.forEach((observable, i) => {
  observable.subscribe(val => {
    console.log('success ' + i);
  }, error => {
    console.log('error ' + i);
  })
})

forkJoin(observables).subscribe(res => {
  console.log('final success');
}, error => {
  console.log('final error');
});

此代码将记录以下内容：

error 1
final error
success 0

我可以使用哪种运算符或回调来执行一些代码在所有可观察对象都成功或出错？目标是按以下顺序登录：

error 1
success 0
final error

另一个可接受的结果是在某处捕获错误并记录：

error 1
success 0
final success

我做了一个演示：https://stackblitz.com/edit/typescript-myfstw?file=index.ts

Answer 1

一种方法是捕获错误并关闭流。

而不是throwError("error") 将管道附加到它throwError("error").pipe(catchError(() => EMPTY))，然后有错误的流简单地完成而没有错误/值。如果你想要一个值，请将EMPTY 替换为of('valueYouWant')。

在原始流中捕获错误很重要，而不是在forkJoin 之后的pipe 中。

自动化你可以做的catchError

let observables: Observable<String>[] = [
  of("string 1").pipe(delay(1000)),
  throwError("error")
].map(obs => obs.pipe(catchError(() => EMPTY)));