如何合并两个Observable？即使其中一个失败也能接收成功结果

核心思路是让每个Observable的错误被内部捕获，不影响其他流的执行，同时单独处理每个流的成功/错误状态，以下是几种可行方案：

方案1：给每个Observable单独封装错误处理（推荐） #

用catchError捕获单个流的错误，将成功/错误状态以结构化数据返回，再用组合操作符统一接收结果，这样不会因为某一个流失败导致整个订阅终止。

先封装一个通用处理函数：

handleObservable<T>(obs: Observable<T>): Observable<{ success: boolean; data?: T; error?: any }> {
  return obs.pipe(
    map(data => ({ success: true, data })),
    catchError(error => of({ success: false, error })),
    untilDestroyed(this)
  );
}

再用combineLatest组合并处理结果：

combineLatest([
  this.handleObservable(this.createTable1()),
  this.handleObservable(this.createTable2())
]).subscribe(([result1, result2]) => {
  // 单独处理第一个流的状态
  if (result1.success) {
    alert('1success');
  } else {
    alert(`1error: ${result1.error.message}`);
  }
  // 单独处理第二个流的状态
  if (result2.success) {
    alert('2success');
  } else {
    alert(`2error: ${result2.error.message}`);
  }
  // 可选：判断整体是否全部成功
  if (result1.success && result2.success) {
    alert('all success');
  }
});

方案2：独立订阅每个Observable #

如果不需要等待两个流都完成再处理，直接分开订阅，两个流完全独立，互不影响：

// 处理第一个Observable
this.createTable1().pipe(untilDestroyed(this)).subscribe(
  () => alert('1success'),
  (error) => alert(`1error: ${error.message}`)
);

// 处理第二个Observable
this.createTable2().pipe(untilDestroyed(this)).subscribe(
  () => alert('2success'),
  (error) => alert(`2error: ${error.message}`)
);

方案3：顺序执行时的错误兼容 #

如果需要先执行第一个流，再执行第二个流（不管第一个是否成功），用concat配合catchError实现：

concat(
  this.createTable1().pipe(
    tap(() => alert('1success')),
    catchError(error => {
      alert(`1error: ${error.message}`);
      return of(null); // 返回空流让concat继续执行下一个Observable
    })
  ),
  this.createTable2().pipe(
    tap(() => alert('2success')),
    catchError(error => {
      alert(`2error: ${error.message}`);
      return of(null);
    })
  )
).pipe(untilDestroyed(this)).subscribe();

原问题原因说明 #

• combineLatest的特性是：只要任一子Observable抛出错误，整个组合流会直接终止并触发错误回调，无法接收其他流的成功结果。
• 嵌套订阅时，第一个Observable失败会直接进入自身的错误回调，不会执行第二个Observable的订阅逻辑，因此无法处理第二个流的状态。

内容的提问来源于stack exchange，提问作者Ortal Blumenfeld Lagziel