我正在寻找一个操作符/一种用rxjs构建可观察性的方法,但我不知道如何做到这一点。
我有两个可观测到的:A和B。
我想以这样的方式组合它们:每当A发出(而且只是A)时,我就可以订阅A和B的最新值。
A: ----1----- 2-------------3--4----5--------6-------|-->
B: --a----------b----a----------------b--------------|-->
// something
C: ----1a-----2a------------3a-4a---5a-------6b------|-->
谢谢你的帮助!
发布于 2017-02-17 02:14:03
您可以使用withLatestFrom
来完全满足您的需要。
const stream1 = Rx.Observable.interval(100)
.map(i => String.fromCharCode(97 + (i % 26)));
const stream2 = Rx.Observable.interval(250);
stream1.withLatestFrom(stream2, (x,y) => `${x}:${y}`)
.take(20)
.subscribe(console.log);
发布于 2017-02-17 02:20:35
根据http://rxmarbles.com/#withLatestFrom和官方医生的说法,我在找withLatestFrom。
我试过用它,但它似乎行不通。我必须错误地使用它:-)也许是因为一个愚蠢的错误!
https://stackoverflow.com/questions/42293911
复制相似问题