如何移除RxJS Observable链内错误处理，交由全局处理器并保留订阅？

要实现「错误交由全局处理器处理，同时保持外层订阅活跃」的需求，核心是避免内部HTTP请求的错误冒泡到外层Observable导致订阅终止。具体修改如下：

修改后的代码 #

import { EMPTY } from 'rxjs';
// onUpdateScale$ is Observable 

this.onUpdateScale$.pipe(
    switchMap(() => this.svc.update(this.getUpdateRequest()).pipe(
        catchError(err => {
            // 将错误交给全局错误处理器处理
            this.globalErrorHandler.handleError(err);
            // 保留原有的失败事件派发（如果业务需要）
            this.mbs.dispatchEvent(this.events.udateScaleFailed);
            // 返回空Observable，避免错误冒泡导致外层订阅终止
            return EMPTY;
        })
    ))
).subscribe({
    next: (data) => {
        // 处理HTTP请求成功后的逻辑
    }
});

关键修改说明 #

• 移除了原有的console.log(err)、return of(undefined)以及后续的filter操作符，因为不再需要通过undefined占位并过滤。
• 在catchError中，将错误传递给全局错误处理器（替换原有的本地日志打印），确保错误被统一处理。
• 返回EMPTY（需从rxjs导入）：这个Observable会立即完成但不发出任何值，既不会触发外层的next回调，也不会向外抛出错误，从而保证onUpdateScale$的订阅始终处于活跃状态，后续新的事件依然能触发HTTP请求。
  • 如果需要内部流永远不完成，也可以替换为never()，但EMPTY更轻量，不会占用额外资源。

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