Observable进入错误状态后finally不执行，如何避免subscribe回调代码重复？

问题根因 #

Observable 有严格的事件契约：一个流的生命周期中，next 通知可以触发0到多次，最终只会触发 error 或 complete 二者之一，不会同时触发。你之前把公共逻辑放在 subscribe 的第三个 complete 回调里，请求出错时只会触发 error 回调，complete 回调自然不会执行，所以逻辑失效。

解决方案：使用 finalize 操作符 #

RxJS 提供的 finalize 操作符完全等价于 Java/C# 里的 finally 语义，无论流是正常完成、抛出错误、还是被主动取消订阅，都会执行内部的回调逻辑，刚好匹配你的需求。

示例代码

首先导入 pipeable 版本的 finalize（RxJS 5.5+ 通用写法）：

import { finalize } from 'rxjs/operators';

改造你的业务代码：

this.loadingResults = true;
this.service.get()
  .pipe(
    finalize(() => {
      this.loadingResults = false;
      this.cd.detectChanges(); 
    })
  )
  .subscribe(
    data => {
      // 处理请求成功的业务逻辑
    },
    err => {
      this.initializeData();
    }
  );

补充说明 #

• 如果使用 RxJS 5.5 之前的旧版本，可以直接调用原型链上的 finally 方法：this.service.get().finally(() => { /* 公共逻辑 */ }).subscribe(...)，但更推荐升级到 pipeable 写法，打包体积更小、tree shaking 效果更好。
• 如果你的请求配置了重试（比如加了 retry/retryWhen 操作符），finalize 会等到所有重试结束、流完全终止后才执行，符合 finally 的通用语义。
• 多页面复用的场景可以把 loading 相关逻辑封装成自定义 RxJS 操作符，进一步减少重复代码。

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