RxJS 5：当所有源Observable发射后，从Observable数组发射单个复合值

首先看你现在的代码思路，是把URI数组转成多个API请求的Observable数组，但直接用map的话，最终得到的是一个发射Observable数组的Observable，而不是等待所有请求完成后发射结果数组的Observable。要实现“所有Observable都发射后输出复合值”的需求，推荐用RxJS的forkJoin操作符——它专门用来处理这种“等待多个Observable都完成，然后收集每个的最后一次发射值”的场景。

修正后的基础实现代码 #

import { apiSvc } from '../lib/api-service';
import { forkJoin } from 'rxjs';
import { map } from 'rxjs/operators';

const uris = [ '/api/items/1', '/api/items/2', '/api/items/3' ];

// 先把每个URI转成对应的API请求Observable
const requestObservables = uris.map(uri => apiSvc.get(uri));

// 用forkJoin等待所有请求完成，统一收集结果
forkJoin(requestObservables).pipe(
  map(results => {
    // results是和uris顺序一一对应的结果数组，比如[item1, item2, item3]
    // 这里可以根据需求生成最终的复合值，比如合并成对象、统计数量等
    return {
      items: results,
      totalCount: results.length,
      success: true
    };
  })
).subscribe({
  next: (finalCompositeValue) => {
    console.log('最终复合值:', finalCompositeValue);
  },
  error: (err) => {
    console.error('某个请求出错:', err);
  }
});

如果要在pipe链中处理上游传来的URI数组 #

如果你的URI数组是从上游Observable发射过来的（比如示例里的observableOf(uris)只是模拟场景），可以结合switchMap和forkJoin来串联逻辑：

import { apiSvc } from '../lib/api-service';
import { of as observableOf } from 'rxjs';
import { switchMap, map } from 'rxjs/operators';
import { forkJoin } from 'rxjs';

const uris = [ '/api/items/1', '/api/items/2', '/api/items/3' ];

observableOf(uris).pipe(
  // 把URI数组转成请求Observable数组，再用forkJoin合并等待完成
  switchMap(uris => forkJoin(uris.map(uri => apiSvc.get(uri)))),
  map(results => {
    // 这里可以自由加工复合值，比如转成键值对对象
    return results.reduce((acc, item, index) => {
      acc[`item${index + 1}`] = item;
      return acc;
    }, {});
  })
).subscribe(finalValue => {
  console.log('最终复合对象:', finalValue);
});

关键细节说明 #

• forkJoin的核心特性：只有当所有传入的Observable都完成时，才会发射一次结果数组；如果任何一个Observable抛出错误，整个forkJoin会直接触发错误回调。
• 如果你的场景是“每个Observable可能多次发射，需要收集所有Observable最近一次发射的值”，那可以用combineLatest，但API请求一般都是单次发射后完成，所以forkJoin是更合适的选择。
• 不要直接用map把URI数组转成Observable数组，因为那样上层Observable发射的是Observable集合，而非实际数据，需要用switchMap（或concatMap/mergeMap）切换到forkJoin的数据流上。

内容的提问来源于stack exchange，提问作者t.888