RxJs中如何获取observable数组所有请求的合并返回结果

你当前的代码逻辑已经可以拿到所有this.http.function3请求的最终结果集合：RxJS的zip操作符会等待所有传入的Observable全部完成后，发射一个对应顺序的结果数组，数组的每一项就是对应id的function3请求返回值，和你注释里的预期一致。

如果要优化语义、增加错误兼容，可以调整为以下写法：

1. 把zip替换为forkJoin：你的所有请求链都是单次返回的HTTP Observable，forkJoin专门用于收集多个单次发射Observable的最终结果，可读性更强。
2. 增加单条请求链的错误捕获，避免单个请求失败导致整个流崩溃，你可以按需选择是否抛出错误或者返回占位值。

改进后的代码示例：

import { forkJoin, of } from 'rxjs';
import { mergeMap, catchError } from 'rxjs/operators';

forkJoin(
  [1, 2, 3].map((id) =>
    this.http.function1(id).pipe(
      mergeMap((obj1) => this.http.function2(obj1.id)),
      mergeMap((obj2) => this.http.function3(obj2.id)),
      // 可选：捕获单条请求的错误，避免整体失败
      catchError((err) => {
        console.error(`id为${id}的请求链失败:`, err);
        // 返回占位值，你也可以按需抛出错误
        return of(null);
      })
    )
  )
).subscribe((result) => {
  // result就是所有function3返回结果组成的数组，顺序和传入的[1,2,3]顺序一致
  console.log('所有function3请求的结果集合:', result);
});

注意事项 #

• 如果你使用的是RxJS 6及以下版本，forkJoin的参数需要保留扩展运算符...，RxJS 7+版本支持直接传入数组。
• 结果数组的顺序和你初始传入的[1,2,3]的顺序完全一致，和请求返回的先后顺序无关。

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