如何将两个Observable数组x$、y$合并为单个最终数组？

嘿，这事儿很简单！你可以借助RxJS的combineLatest操作符来实现，它专门用来组合多个Observable的最新值，完美匹配你需要合并两个数组的场景。

具体实现代码 #

import { BehaviorSubject, combineLatest } from 'rxjs';
import { map } from 'rxjs/operators';

// 你的初始定义
let x = new BehaviorSubject([1,2,3]);
let y = new BehaviorSubject([4,5,6]);
let x$ = x.asObservable();
let y$ = y.asObservable();

// 合并两个Observable数组
const combinedArray$ = combineLatest([x$, y$]).pipe(
  // 解构出两个最新数组，然后展开合并
  map(([xArray, yArray]) => [...xArray, ...yArray])
);

// 订阅结果
combinedArray$.subscribe(mergedArray => {
  console.log(mergedArray); // 首次输出：[1,2,3,4,5,6]
});

// 额外测试：如果后续更新x或y的值，订阅会自动收到新的合并结果
x.next([7,8,9]); // 此时会输出：[7,8,9,4,5,6]
y.next([10,11]); // 此时会输出：[7,8,9,10,11]

为什么用combineLatest？ #

• 它会等待所有输入的Observable至少发出一次值（你的BehaviorSubject一开始就有初始值，所以订阅后立刻触发）
• 每当任意一个Observable发出新值时，它会把所有Observable的最新值组合起来，确保你总能拿到两个数组的最新状态合并结果

如果你考虑用forkJoin的话，它需要等每个Observable都完成才会发出值，但BehaviorSubject默认不会自动完成，除非你手动调用x.complete()和y.complete()，所以combineLatest是更适合的选择。

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