如何在RxJS forkJoin中捕获错误后忽略并执行最终结果

这问题我做项目时也碰到过，核心思路就是给需要忽略错误的请求（fn2、fn3）在catchError里返回一个能正常完成的Observable，这样forkJoin就不会因为这两个请求失败而中断，同时保留fn1的错误抛出逻辑。

具体实现步骤 #

• 对于fn1：保持你原本的逻辑，在catchError里抛出错误，这样当fn1失败时，整个forkJoin会触发error回调，满足你需要处理这个错误的需求。
• 对于fn2和fn3：在catchError中用of()操作符返回一个默认值（比如null、空数组或者符合业务的默认结构），这样这个Observable会正常完成，forkJoin会把这个默认值当作该请求的结果，继续执行subscribe的next回调。

修改后的代码 #

myfunc() { 
  const combined = forkJoin( 
    // fn1报错时抛出错误，中断整个流并触发error处理
    this.service.fn1(parameter).pipe( 
      catchError(err => { throw this.handleError(err); }), 
    ), 
    // fn2报错时返回null作为默认值，不中断流
    this.service2.fn2().pipe( 
      catchError(err => of(null)), 
    ),
    // fn3报错时返回默认值，不中断流
    this.service3.fn3().pipe( 
      catchError(err => of(null)) 
    )); 
  const subscribe = combined.subscribe ( 
    ([fn1Result, fn2Result, fn3Result]) => { 
      // 这里会正常执行，哪怕fn2/fn3失败，它们的结果会是你设置的默认值
      console.log('fn1结果:', fn1Result);
      console.log('fn2结果（失败则为null）:', fn2Result);
      console.log('fn3结果（失败则为null）:', fn3Result);
      // 你的业务逻辑代码
    },
    (error) => {
      // 只有fn1失败时才会进入这里，处理fn1的错误
      console.error('fn1请求出错:', error);
    }
  ); 
}

原理说明 #

forkJoin的特性是：只有当所有传入的Observable都正常完成时，才会把所有结果汇总后发出next通知；如果任何一个Observable报错，整个forkJoin会立即触发error通知，终止流。

通过给fn2、fn3的catchError返回一个用of()创建的Observable，我们把“报错的流”转换成了“正常完成并发出默认值的流”，这样forkJoin就能顺利收集所有结果，执行subscribe的next回调。而fn1保留抛出错误的逻辑，确保它出错时整个流进入error回调，完全符合你的需求。

内容的提问来源于stack exchange，提问作者Ramya S