RxJS:结合observables,当源发出并检索其他值的最后值时发出
问题描述:
我正在寻找一个运算符/一种构建rxjs的observable的方法,但我不明白如何执行此操作。RxJS:结合observables,当源发出并检索其他值的最后值时发出
我有两个观测:A和B.
我想他们这种方式结合的:每当发出(和公正A),我可以订阅的最新值和B
A: ----1----- 2-------------3--4----5--------6-------|-->
B: --a----------b----a----------------b--------------|-->
// something
C: ----1a-----2a------------3a-4a---5a-------6b------|-->
感谢您的帮助!
答
您可以使用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);
答
根据rxmarbles:http://rxmarbles.com/#withLatestFrom和the official doc我一直在寻找withLatestFrom。
我试过使用它,但它似乎不起作用。我必须以错误的方式使用它:-)也许这是因为一个愚蠢的错误!