共通のイベントプロパティで2つのイベントストリームを結合するにはどうすればよいですか？

Question

次の2つのイベントストリームを検討してください。すべてのイベントにタイムスタンプ/ tsおよびvalueプロパティがあります。

Iは値の適用される変換して得られた流れの中に、イベントが同じタイムスタンプを有するこれら2つのストリームを結合します。 1つのストリームに1つのタイムスタンプがない場合（下の例では黄のts=3など）、そのタイムスタンプは無視してください。

などxstreamやrxjs等の反応性プログラミングライブラリを使用して問題を解決したいと思います。私はリアクティブプログラミングの概念にはかなり新しいですが、誰かが別の提案をしているなら私はすべて耳です。ありがとう！

Answer 1

combineLatestを使用して、一致するタイムスタンプを持つ組み合わせのみを渡します。他の組み合わせはnullにマップされ、後で除外します。

はここXStreamの中ソリューションです：

var streamOut = xs.combine(
    (a, b) => { 
    if (a.ts === b.ts) { 
     return {ts: a.ts, value: a.value + b.value}; 
    } else { 
     return null; 
    } 
    }, 
    streamA, streamB 
).filter(x => x !== null); 

はJSBinで実行されていることを確認してください：https://jsbin.com/saxawatuza/edit?js,console。