如何判断Observable是异常终止还是正常完成并执行对应代码？

嘿，这个场景太常见了！finalize确实会在Observable终止时（不管是正常完成还是抛出错误）都触发，所以没法直接区分状态。不过RxJS里完全有办法分别处理这两种情况，而且现在的API已经很清晰了～

直接用tap操作符区分处理 #

从RxJS 6开始，原来的doOnComplete、doOnError这类操作符已经被统一整合到tap里了。你可以给tap传入一个配置对象，分别指定complete和error的回调函数：

const obs = getMyObservable().pipe(
  tap({
    // 正常完成时触发
    complete: () => {
      console.log('✅ Observable正常完成，执行对应逻辑');
      // 这里写正常完成后的业务代码
    },
    // 错误终止时触发
    error: (error) => {
      console.error('❌ Observable因错误终止:', error);
      // 这里写错误处理逻辑
    }
  }),
  finalize(() => {
    // 如果你有不管成功失败都要执行的收尾逻辑，比如清理资源，放在这里
    console.log('🔚 不管结果如何，我都会执行');
  })
);

另一种方式：分开处理错误和完成 #

如果你更喜欢拆分逻辑，也可以单独用catchError处理错误（注意catchError需要返回一个新的Observable，否则会中断流），再用tap处理完成：

import { catchError, throwError } from 'rxjs';

const obs = getMyObservable().pipe(
  tap({
    complete: () => {
      console.log('✅ 正常完成');
    }
  }),
  catchError((error) => {
    console.error('❌ 错误终止:', error);
    // 如果你想让流继续向下传递，可以返回一个空Observable或者默认值
    // 如果不想继续，直接抛出错误即可
    return throwError(() => error);
  }),
  finalize(() => {
    // 通用收尾逻辑
  })
);

小提醒 #

• 旧版本RxJS（5及以前）确实有doOnComplete和doOnError，但现在已经被废弃了，推荐用tap替代，API更统一。
• tap里的error回调只是监听错误，不会改变流的走向，错误依然会向下传递；而catchError会捕获错误，你可以决定是否让流继续。

内容的提问来源于stack exchange，提问作者Héctor Valls