合并两个 RxJS 流（基于同步）

Question

我有两个 RxJS 主题，比如 a 和 b，我需要以某种方式组合。

someComboOfAandB.subscribe({aVal, bVal} => console.log("value:", aVal, bVal));

我想将它们组合起来，如果a 和b 同步更新，则值会一起传递：

a.next(1);
// some code
b.next(2)

// at end of synchronous code / frame:
// value: 1 2

但是，如果只更新一个值，则仍会同时推送一个更新，同时推送具有两个新值的更新：

a.next(5)

// at end of synchronous code / frame:
// value: 5 2

这可能吗？如果是，那又如何？即使有可能，也应该避免吗？

Answer 1

您应该能够使用Scheduler 来实现您想要的行为：

import "rxjs/add/observable/combineLatest";
import "rxjs/add/operator/map";

import { BehaviorSubject } from "rxjs/BehaviorSubject";
import { Observable } from "rxjs/Observable";
import { asap } from "rxjs/scheduler/asap";

let a = new BehaviorSubject(1);
let b = new BehaviorSubject(2);
let combined = Observable
    .combineLatest(a, b, asap)
    .map((values) => ({ aVal: values[0], bVal: values[1] }));

combined.subscribe(
    ({ aVal, bVal }) => { console.log("value:", aVal, bVal); }
);

a.next(3);
b.next(4);

上面的代码会输出如下：

value: 3 4

如果未指定asap Scheduler，则输出为：

value: 1 2
value: 3 2
value: 3 4

RxJS GitHub 存储库包含一些 Scheduler documentation。