RxJS：结合observables，当源发出并检索其他值的最后值时发出

Question

我正在寻找一个运算符/一种构建rxjs的observable的方法，但我不明白如何执行此操作。

我有两个观测：A和B.

我想他们这种方式结合的：每当发出（和公正A），我可以订阅的最新值和B

A: ----1----- 2-------------3--4----5--------6-------|--> 
B: --a----------b----a----------------b--------------|--> 
// something 
C: ----1a-----2a------------3a-4a---5a-------6b------|--> 

感谢您的帮助！

Answer 1

您可以使用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); 

Answer 2

根据rxmarbles：http://rxmarbles.com/#withLatestFrom和the official doc我一直在寻找withLatestFrom。

我试过使用它，但它似乎不起作用。我必须以错误的方式使用它:-)也许这是因为一个愚蠢的错误！