如何在流内部判断订阅是否定义了错误处理函数

现有以下代码：

function getData() {
    return this.http.get('data');
}

// 调用示例
getData().subscribe({
   complete: () => {
      this.closeDialog();
   }
});

这段代码未经过测试，但预期可以运行。不过this.http调用可能抛出错误，目前有两种错误处理方式：

1. 在订阅时添加error处理函数：

getData().subscribe({
   error: (err) => { this.showNotification(err) },
   complete: () => { this.closeDialog() }
});

2. 在getData内部捕获错误：

function getData() {
    return this.http.get('data').pipe(catchError(err => {
        return of({});
    }));
}

需求是实现：

• 如果subscribe定义了error处理函数，则不在getData内部捕获错误
• 如果subscribe未定义error处理函数，则在getData内部捕获错误

请问这是否可行？如果不可行，求其他解决方案。

可行性结论 #

直接实现“自动感知订阅者是否定义error处理函数”不可行。因为Observable是冷数据流，getData返回Observable时，还未被订阅，无法提前知晓后续订阅者的错误处理逻辑。

推荐解决方案 #

最清晰且易维护的方式是给getData添加一个可选参数，让调用方显式指定是否需要内部捕获错误，以此替代隐式判断：

1. 修改getData函数

import { catchError, of } from 'rxjs';

function getData(catchErrors = true) {
  const request$ = this.http.get('data');
  
  // 根据参数决定是否添加内部错误捕获
  if (catchErrors) {
    return request$.pipe(
      catchError(err => {
        // 这里可以添加自定义的默认错误处理逻辑
        console.error('请求出错:', err);
        return of({}); // 返回默认空数据
      })
    );
  }
  
  return request$;
}

2. 调用示例

• 当需要自行处理错误时，传入false禁用内部捕获：

getData(false).subscribe({
  error: (err) => { this.showNotification(err) },
  complete: () => { this.closeDialog() }
});

• 当不需要自行处理错误时，使用默认参数，由getData内部捕获：

getData().subscribe({
  complete: () => { this.closeDialog() }
});

补充说明 #

这种显式参数的方式比隐式判断更符合代码可读性原则，避免了“魔法行为”带来的维护成本。如果追求更灵活的设计，也可以将默认错误处理逻辑抽离成独立函数，让调用方可以按需替换，但显式参数的方案在大多数场景下已经足够简洁实用。

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