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。

我試過使用它，但它似乎不起作用。我必須以錯誤的方式使用它:-)也許這是因爲一個愚蠢的錯誤！