RXJS Observables：批量HTTP请求合并单结果实现疑问

你的问题根源在于用了concatMap——它会逐个处理每个成员的请求，每完成一个就返回一次当前的数组，所以控制台会依次输出1个、2个...元素的数组。而forkJoin正是用来解决这种「等待所有异步请求完成后，一次性返回所有结果」的场景，下面是调整后的代码：

getStats(tag: string) {
  return this.service.getClanByClanTag(tag).pipe(
    map(clan => clan.memberList), // 获取成员列表数组
    switchMap((members: PlayerByMemberListType[]) => {
      // 把每个成员转换成一个Observable，每个Observable返回合并后的成员数据
      const memberRequestObservables = members.map(member => {
        return this.service.getPlayerData(member.tag).pipe(
          map(player => ({
            tag: member.tag,
            name: member.name,
            warStars: player.warStars,
            trophiesNightBase: member.versusTrophies
          }))
        );
      });
      
      // forkJoin会等待所有请求完成，然后返回包含所有结果的数组
      return forkJoin(memberRequestObservables);
    })
  );
}

关键调整说明： #

1. 移除了外部的newArr：不需要手动维护数组，forkJoin会自动把每个请求的结果收集成一个数组返回。
2. 用map把成员转成Observable数组：对每个成员，创建一个获取玩家数据的Observable，并在内部完成「成员基础信息 + 玩家统计数据」的合并。
3. forkJoin替代concatMap的逐个输出：forkJoin会等待所有请求都完成后，一次性emit最终的完整结果数组，这样控制台只会输出一次包含所有成员数据的数组。

额外提示： #

• 如果你的RxJS版本是5.x，不需要用pipe包裹操作符，直接链式调用map/switchMap即可，但推荐升级到6+版本使用pipe的写法。
• 如果某个成员的请求失败，forkJoin会直接抛出错误。如果需要容错，可以给每个内部Observable添加catchError，比如返回一个默认值，避免整个请求失败：

  return this.service.getPlayerData(member.tag).pipe(
    map(player => ({ /* ... */ })),
    catchError(() => of({
      tag: member.tag,
      name: member.name,
      warStars: 0,
      trophiesNightBase: member.versusTrophies
    }))
  );
  

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