如何在订阅Observable前于Angular的RestService中处理特定响应？

可以通过在RestService的post方法管道中添加自定义RxJS操作符，统一处理空数组、{"status": "KO"}这类特定响应，避免在每个订阅块中重复写判断逻辑。

方案1：将特定响应转为错误（推荐） #

把不符合预期的响应转为错误，交由已有的catchHttpErrors统一处理，或者让调用方通过catchError按需处理。

修改rest-service.ts：

import { MonoTypeOperatorFunction, Observable, throwError } from 'rxjs';
import { map } from 'rxjs/operators';

protected post<T>(url: string, data: any = null): Observable<T> {
  return this.http.post<T>(url, data, { withCredentials: true }).pipe(
    this.handleSpecialResponses(), // 新增特定响应处理
    this.catchHttpErrors(options)
  );
}

// 自定义操作符：检查并处理特定响应
private handleSpecialResponses<T>(): MonoTypeOperatorFunction<T> {
  return (source: Observable<T>) => source.pipe(
    map(response => {
      // 处理status为KO的响应
      if (typeof response === 'object' && response !== null && 'status' in response && response.status === 'KO') {
        throw new Error('请求状态异常：KO');
      }
      // 处理空数组响应
      if (Array.isArray(response) && response.length === 0) {
        throw new Error('响应为空数组');
      }
      // 符合预期的响应直接返回
      return response;
    })
  );
}

调用方（example-service.ts）的使用示例：

exampleRequest(url: string, data: ExampleData): Observable<ExampleEntity> {
  return this.restService.post<ExampleEntity>(url, data).pipe(
    catchError(error => {
      // 按需处理RestService抛出的特定错误
      console.error('请求出错:', error.message);
      // 返回默认值或重新抛出错误
      return of(this.getDefaultExampleEntity());
    })
  );
}

方案2：直接在服务中处理（不抛出错误） #

如果不需要把特定响应转为错误，只是想统一执行逻辑（比如弹窗提示、日志记录），可以用tap操作符：

修改rest-service.ts中的自定义操作符：

import { MonoTypeOperatorFunction, Observable } from 'rxjs';
import { tap } from 'rxjs/operators';

private handleSpecialResponses<T>(): MonoTypeOperatorFunction<T> {
  return (source: Observable<T>) => source.pipe(
    tap(response => {
      if (typeof response === 'object' && response !== null && 'status' in response && response.status === 'KO') {
        // 统一执行KO状态的处理逻辑，比如提示用户
        this.alertService.error('请求失败，请稍后重试');
      }
      if (Array.isArray(response) && response.length === 0) {
        // 统一处理空数组的逻辑，比如提示无数据
        this.alertService.info('暂无数据');
      }
    })
  );
}

这种方式下，调用方的订阅逻辑不需要做任何修改，就能自动触发服务中定义的统一处理逻辑。

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