RXJS中异步流是如何传输的？

我试图了解流是如何通过 RXjs 中的管道传输的。
我知道这不应该成为一个问题，因为这就是异步流的整个想法 - 但仍然有一些我想理解的事情。

看这段代码：

var source = Rx.Observable
    .range(1, 3)
    .flatMapLatest(function (x) {  //`switch` these days...
        return Rx.Observable.range(x*100, 2);
    });


 source.subscribe(value => console.log('I got a value ', value))

Result :

I got a value 100
I got a value 200
I got a value 300
I got a value 301

我相信（IIUC）该图是这样的：（通知已取消订阅 101,201）

----1---------2------------------3------------------------------|

░░░░░░░░flatMapLatest(x=>Rx.Observable.range(x*100, 2))░░░░░░░░
-----100-------(-̶1̶0̶1̶)-------200---(-̶2̶0̶1̶)-----300------301-------------

这是问题：

问题：

是否总是保证 2 会在 (101) 之前到达？与 (201) 之前到达的 3 相同？

我的意思是 - 如果我不打算查看时间线，那么出现下图是完全合法的：

----1---------------2---------------3------------------------------|

░░░░░░░░flatMapLatest(x=>Rx.Observable.range(x*100, 2))░░░░░░░░
-----100-------101------200---201-----300------301-------------

Where 2到达时略有延迟，其中 101 已发出

我在这里缺少什么？这里的管道是如何工作的？

对于具有特定 RxJS 版本的特定 Observable 链，排放顺序将始终相同。

正如已经提到的，在 RxJS 4 中它使用currentThread调度程序，如下所示：https://github.com/Reactive-Extensions/RxJS/blob/master/src/core/perf/operators/range.js#L39 https://github.com/Reactive-Extensions/RxJS/blob/master/src/core/perf/operators/range.js#L39.
所有调度程序（除了immediate来自 RxJS 4) 是内部使用某种类型的队列 https://github.com/Reactive-Extensions/RxJS/blob/master/src/modular/scheduler/currentthreadscheduler.js#L29所以顺序总是一样的。

事件的顺序与您在图中显示的非常相似（......或者至少我认为是这样）：

1. 1被调度并发出，因为它是队列中唯一的操作。
2. 100已安排。此时调度程序的队列中没有更多操作，因为2尚未安排。这RangeObservable 在调用后递归地安排另一个发射onNext() https://github.com/Reactive-Extensions/RxJS/blob/master/src/modular/observable/range.js#L19。这意味着100被安排在之前2.
3. 2已安排 https://github.com/Reactive-Extensions/RxJS/blob/master/src/modular/observable/range.js#L20.
4. 100被发射，101已安排
5. 2被发射，101被处置。
6. ... 等等

请注意，这种行为在 RxJS 4 和 RxJS 5 中是不同的。

在 RxJS 5 中，大多数 Observables 和运算符默认不使用任何 Scheduler（一个明显的例外是需要处理延迟的 Observables/operator）。所以在RxJS 5 的RangeObservable不会安排任何事情 https://github.com/ReactiveX/rxjs/blob/9ec444e1a053a882d714b9cb4bc92c898152e4b7/src/observable/RangeObservable.ts#L89并立即开始循环发出值。

RxJS 5 中的相同示例将产生不同的结果：

const source = Observable
  .range(1, 3)
  .switchMap(function (x) {
    return Observable.range(x * 100, 2);
  });

source.subscribe(value => console.log('I got a value ', value));

这将打印以下内容：

I got a value  100
I got a value  101
I got a value  200
I got a value  201
I got a value  300
I got a value  301

但是，如果您添加例如delay(0)。常识表明这不应该做任何事情：

const source = Observable
  .range(1, 3)
  .switchMap(function (x) {
    return Observable.range(x * 100, 2).delay(0);
  });

source.subscribe(value => console.log('I got a value ', value));

现在只剩下内在RangeObservable被多次调度和处理，这使得它只发出最后一次的值RangeObservable:

I got a value  300
I got a value  301