2

看定义_combineLatest

组合多个 Observable 以创建一个 Observable，其值是根据其每个输入 Observable 的最新值计算得出的。

或者

每当任何输入 Observable 发出一个值时，它都会使用来自所有输入的最新值计算一个公式，然后发出该公式的输出。

在此处输入图像描述

很清楚地看到，在每个时间段/排放量中，该排放量的结果是最新排放量的组合。

如果是这样，请查看此代码

const obs1 = Rx.Observable.of(1, 2, 3, 4, 5);
const obs2 = Rx.Observable.of('a', 'b', 'c')
const obs3 = obs2.combineLatest(obs1, (a, b) => a+b);

const subscribe = obs3.subscribe(latestValues => {
  console.log(latestValues   );
});

结果是：

c1,c2,c3,c4,c5

当我改变

obs2.combineLatest(obs1..

至

obs1.combineLatest(obs2..

——我明白了5a,5b,5c

问题：

文档没有指定关于调用顺序的任何区别（如果是这样 - 为什么我会得到不同的结果）？

为什么我看不到其他来源的其他组合？似乎一个来源正在获取它的最后一个值，然后才将它加入到来自 OTHER 来源的每个值中。

看起来这就是实际发生的事情：

[other source]---a---b---c------------------------
[first source]-------------1----2-----3-----4----5
[result]-------------------c1---c2----c3----c4---c5

当我交换订单时 (obs1<->obs2) ：

[first source]-----1--2---3--4--5----------------
[other source]---------------------a-----b------c
[result]---------------------------5a----5b-----5c

这里发生了什么？为什么一个流必须完成才能开始加入？

为什么我看不到这样的东西（或变体）：

[first source]-----1-----2--------3-------4------5---
[other source]---------a-----b------c----------------
[result]---------------1a------2b------3b---4c-------5c

JSBIN

4

1 回答 1

4

这是因为来自源 Observable 的值是同步发出的，除非你使用调度器。这意味着首先obs1发出所有值，只有最后一个被记住，combineLatest然后obs2开始发出所有值（如果切换两个 Observable，同样适用）。现在combineLatest两个 Observables 都有值，所以来自第二个 Observables 的任何发射都会使操作员发射一个值。

为什么它会这样工作，因为它Observable.of是在内部实现的ArrayObservable，默认情况下它不使用任何调度程序。这意味着它的所有排放都是同步发生的。见https://github.com/ReactiveX/rxjs/blob/master/src/observable/ArrayObservable.ts#L118

顺便说一句，您可以将Rx.Scheduler.async作为最后一个参数添加到两个源 Observables。

于 2017-04-25T21:47:42.717 回答