RxJS 5 merge操作符表现异常，如何实现数组Observable并发取值？

这个问题其实是RxJS 5调度器模型变化导致的，我来帮你拆解原因和解决办法：

为什么RxJS 5里merge表现得像concat？ #

RxJS 5中，Observable.from默认是同步执行的。当你把两个同步Observable传给merge时，RxJS会先完全订阅第一个Observable，同步发射它的所有值，之后才会订阅第二个Observable。这就导致输出看起来和concat完全一致，但这并不是merge本身的问题——它只是在同步场景下的特殊表现。而RxJS 4的调度器行为不同，会交替处理同步流的发射事件。

在RxJS 5中实现并发取值的几种方法 #

要让merge真正并发处理两个数组Observable，你需要把同步流转换成异步流，给merge交替处理的机会：

1. 使用async调度器（最推荐）

在from方法中指定Rx.Scheduler.async，让每个值的发射进入异步队列：

Rx.Observable.merge(
  Rx.Observable.from([1,2,3,4], Rx.Scheduler.async),
  Rx.Observable.from([5,6,7], Rx.Scheduler.async)
).subscribe(i => console.log(i));

这样输出会类似RxJS 4的交替结果（比如1,5,2,6,3,7,4，具体顺序可能因异步调度略有波动，但确实是并发发射）。

2. 用delay(0)转为异步流

delay(0)会把发射逻辑放到下一个事件循环，同样能触发merge的并发行为：

Rx.Observable.merge(
  Rx.Observable.from([1,2,3,4]).delay(0),
  Rx.Observable.from([5,6,7]).delay(0)
).subscribe(i => console.log(i));

3. 可控间隔的异步发射（适合需要节奏的场景）

如果需要每个值按固定间隔发射，可以用interval配合map来构建流：

const stream1 = Rx.Observable.interval(100).take(4).map(num => num + 1);
const stream2 = Rx.Observable.interval(100).take(3).map(num => num + 5);

Rx.Observable.merge(stream1, stream2).subscribe(i => console.log(i));

这个方案会稳定输出1,5,2,6,3,7,4这类交替结果，完全符合并发的预期。

补充说明 #

RxJS 5的merge本身是完全支持并发的，只是同步Observable的特性让它在这个场景下表现特殊。RxJS 5对调度器模型做了优化，优先处理同步流以减少不必要的异步开销，同时保持行为的可预测性——只要把流转为异步，merge的并发能力就会正常体现。

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