Angular服务中基于RxJS Pipeline筛选验证文档的实现求助

需求梳理 #

• 先过滤掉Name属性为空的文档
• 对过滤后的文档，依次完成双重API验证：
  1. 调用第一个API，对比返回结果与文档指定属性，验证通过才进入下一步
  2. 调用第二个API，对比返回结果与文档另一属性，验证通过则保留该文档
• 最终返回所有通过双重验证的文档数组

原代码问题分析 #

• 未保留原文档引用，API调用后无法对比原文档属性
• 缺少验证失败时跳过当前文档的逻辑
• 未添加最终收集结果的操作符

完整实现代码 #

import { from, EMPTY, Observable } from 'rxjs';
import { filter, concatMap, toArray, map, catchError } from 'rxjs/operators';

// 假设你的Doc接口定义
interface Doc {
  Name: string;
  docId: string; // 用于第一个API验证的属性
  contentHash: string; // 用于第二个API验证的属性
}

processValidDocuments(listOfDocs: Doc[]): Observable<Doc[]> {
  return from(listOfDocs).pipe(
    // 第一步：过滤Name为空的文档
    filter(doc => !!doc.Name),
    // 第二步：调用第一个API并验证
    concatMap(doc => 
      this.myApiService.getDoc(doc.docId).pipe(
        // 示例验证逻辑：对比API返回的ID与原文档ID
        map(apiResponse => {
          return apiResponse.id === doc.docId ? doc : EMPTY;
        }),
        // API调用失败时跳过当前文档
        catchError(() => EMPTY)
      )
    ),
    // 第三步：调用第二个API并验证
    concatMap(doc => 
      this.mySecondApiCall.verifyHash(doc.contentHash).pipe(
        // 示例验证逻辑：对比API返回的哈希值与原文档哈希
        map(apiHashResult => {
          return apiHashResult.validHash === doc.contentHash ? doc : EMPTY;
        }),
        // API调用失败时跳过当前文档
        catchError(() => EMPTY)
      )
    ),
    // 第四步：收集所有通过验证的文档为数组
    toArray()
  );
}

关键逻辑说明 #

• from(listOfDocs)：将文档数组转换为可观察流，实现逐个处理单文档
• filter(doc => !!doc.Name)：简化过滤逻辑，直接判断Name是否非空
• concatMap：确保API调用按顺序执行（若允许并发可替换为mergeMap），每个API调用内部：
  • 调用API后通过map对比返回结果与原文档属性
  • 验证通过返回原文档，不通过返回EMPTY（流会自动跳过该值）
  • catchError(() => EMPTY)：单个API调用失败时跳过当前文档，避免整个流中断
• toArray()：将所有通过双重验证的文档收集为数组返回

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