如何链式调用两个forkJoin使第二个调用可使用第一个返回数据？

问题根源 #

出现嵌套Observable、需要嵌套subscribe的核心原因是错误使用了map操作符：map只会对返回值做直接映射，如果你在map里返回Observable，它会把这个Observable本身作为普通值传给下游，不会自动订阅执行内部逻辑，因此才会出现Observable<{a: Observable, b: Observable, c: Observable}>的嵌套类型，被迫写嵌套subscribe。

正确实现方式 #

用高阶映射操作符（switchMap/concatMap/mergeMap均可，此场景下效果完全一致）替换map，这类操作符会自动订阅内部返回的Observable，将内层流的输出打平传给下游，同时全链路的错误都会统一传递到最终的subscribe回调，不需要分开配置错误处理器。
完整实现代码：

import { forkJoin } from 'rxjs';
import { switchMap } from 'rxjs/operators';

// 第一组forkJoin拉取基础数据
forkJoin({
  a: getObservableA(),
  b: getObservableB(),
  c: getObservableC()
}).pipe(
  // 拿到第一组结果后，构造依赖第一组结果的第二组Observable
  switchMap(firstResult => forkJoin({
    a2: processA(firstResult.a),
    b2: processB(firstResult.b),
    c2: processC(firstResult.c)
  }))
).subscribe({
  next: finalResult => {
    // 此处拿到的就是第二组forkJoin的最终输出 {a2: xxx, b2: xxx, c2: xxx}
    // 直接处理业务逻辑即可，不需要嵌套subscribe
  },
  error: err => {
    // 全链路错误统一捕获：第一组任意请求报错、第二组process逻辑/请求报错都会走到这里
    // 不需要分开写两个错误处理回调
  }
})

额外说明 #

• 如果你提到的processA/processB/processC是同步执行、直接返回普通值的函数，根本不需要第二个forkJoin，直接在map里返回处理后的普通对象即可，示例：

  forkJoin({
    a: getObservableA(),
    b: getObservableB(),
    c: getObservableC()
  }).pipe(
    map(firstResult => ({
      a2: processA(firstResult.a),
      b2: processB(firstResult.b),
      c2: processC(firstResult.c)
    }))
  ).subscribe({
    next: finalResult => { /* 处理结果 */ },
    error: err => { /* 统一处理错误 */ }
  })
  

• 你之前写的第二种错误写法，本质是把未被订阅的Observable直接作为值传给了forkJoin，forkJoin只会等待传入的Observable完成，不会自动订阅你作为值返回的Observable，因此不会执行processX对应的逻辑。
• 嵌套subscribe是RxJS公认的反模式，除了代码可读性差，还会导致内层订阅无法随外层取消订阅自动清理、错误无法统一冒泡传递等问题，所有需要嵌套subscribe的场景都可以通过对应高阶映射操作符替代。

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