如何用另一个Observable的值更新目标Observable的结果？

你可以使用RxJS的高阶映射操作符（比如switchMap、concatMap或mergeMap）消除嵌套subscribe，同时返回一个能输出最终更新后对象的Observable。其中switchMap是HTTP请求场景下最常用的选择，它会自动取消前一个未完成的请求，避免不必要的资源浪费。

优化后的代码示例 #

// 返回可后续订阅的 Observable<MyObject>
return this._http.get<JSON>(url, { params })
  .pipe(
    // 第一步：把接口返回的JSON转换成目标对象
    map(res => this.getObjectFromJson(res)),
    // 第二步：基于当前对象发起第二个请求，替换嵌套subscribe
    switchMap(myObject => 
      this.getValueToUpdate(myObject).pipe(
        // 第三步：拿到新值后更新对象，返回最终结果
        map(newValue => {
          myObject.some.value = newValue;
          return myObject;
        })
      )
    )
  );

操作符说明 #

• map: 负责将HTTP响应的JSON数据转换为你的MyObject实例，是纯数据转换操作。
• switchMap: 属于高阶映射操作符，它接收前一步输出的myObject，并发起第二个Observable（getValueToUpdate）。如果前一个请求还未完成就触发新的请求，switchMap会自动取消前一个请求，适合处理HTTP这类单次响应的流。
• 内部的**map**: 拿到newValue后更新myObject的属性，然后将更新后的对象作为最终Observable的输出。

可选优化：处理不可变对象 #

如果你的MyObject是不可变对象（不允许直接修改原对象），可以返回一个新的对象实例：

map(newValue => ({
  ...myObject,
  some: {
    ...myObject.some,
    value: newValue
  }
}))

其他高阶操作符的适用场景 #

• concatMap: 会按顺序执行请求，前一个请求完成后才会发起下一个，适合需要保证执行顺序的场景。
• mergeMap: 允许并行发起多个请求，适合不关心执行顺序且需要提高效率的场景。

优化后的Observable可以直接被后续代码订阅，或者继续通过pipe添加其他操作符，完全符合RxJS的链式编程风格，避免了嵌套subscribe带来的回调地狱问题。

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