2017-02-17 7 views
1

rxjsで観測値を構築する演算子/方法を探していますが、これを行う方法はわかりません。私は彼らにこの方法を組み合わせたいAとBRxJS:観測値を結合して、ソースが他のものの最終値を出し出したときに放射します

私は2つの観測を持っているときは常に発光する(とちょうどA)、私は最新のAの値とB

A: ----1----- 2-------------3--4----5--------6-------|--> 
B: --a----------b----a----------------b--------------|--> 
// something 
C: ----1a-----2a------------3a-4a---5a-------6b------|--> 
を購読することができます

ご協力いただきありがとうございます。私はwithLatestFromを探していたhttp://rxmarbles.com/#withLatestFromthe official doc

答えて

0

あなたがrxmarblesによる

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); 
0

を必要とする正確に何を行うにwithLatestFromを使用することができます。

私はそれを使用しようとしましたが、動作しないようです。私はそれを間違った方法で使う必要があります:-)多分それは愚かな間違いのためです!

関連する問題