合并两个Observable并复用数据：寻求更简洁的实现方案

嘿，你说的这个场景正好是RxJS合并操作符的拿手好戏！你当前的实现虽然能跑，但确实可以用更简洁的方式来处理，我给你梳理几个最适合的方案：

首选：forkJoin（完美匹配你的需求） #

如果你的两个Observable都是只发射一次值就完成（比如HTTP请求、单次计算类的Observable），并且你需要等待两者都完成后再调用doSomethingWithThese，那forkJoin就是最贴合的选择——它会并行订阅所有传入的Observable，只有当所有Observable都完成时，才会把每个Observable的最后一个值打包成数组返回。

代码示例：

import { forkJoin } from 'rxjs';

// 假设你的两个返回Observable的函数是func1、func2，传入的变量是var1、var2
const observable1 = func1(var1);
const observable2 = func2(var2);

forkJoin([observable1, observable2])
  .subscribe(([resultFromFunc1, resultFromFunc2]) => {
    // 直接解构数组得到两个结果，传给目标函数
    doSomethingWithThese(resultFromFunc1, resultFromFunc2);
  });

注意事项 #

• 如果其中任何一个Observable永远不完成（比如一个持续发射值的定时器Observable），forkJoin也永远不会发出值，所以要确保你的func1和func2返回的Observable最终会完成。

备选：combineLatest（适合持续发射值的场景） #

如果你的Observable是会持续发射新值的（比如监听输入框变化的Observable），并且你想要每次任一Observable发射新值时都调用doSomethingWithThese，那可以用combineLatest：

import { combineLatest } from 'rxjs';

combineLatest([observable1, observable2])
  .subscribe(([result1, result2]) => {
    doSomethingWithThese(result1, result2);
  });

它会在每个Observable至少发射过一次值后，每当其中任一Observable发射新值时，就把所有Observable的最新值组合起来返回。

对比你之前的手动实现，这些合并操作符帮你省去了手动管理订阅状态、保存中间结果的代码，逻辑更清晰也更符合RxJS的响应式编程理念。

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