.net - Rxを使用して2つのストリームを同期する

Question

マスターソースからのデータのストリームと、別のソースからのエンリッチメントデータを含む2番目のストリームがあります。残念ながら、エンリッチメントメッセージは元のデータの前に届くことがよくあります。元のメッセージが最初に公開されるまで、エンリッチメントメッセージが確実にバッファリングされるようにしたいと思います。Rxでこれを達成できますか？

Answer 1

短い答え、おそらく。@Enigmativityも避けられたように、これはやや自由形式の質問として立っています。

1. 1対1のメッセージはありますか（明らかにありません-'エンリッチメント値がない可能性があります'）
2. エンリッチメントメッセージとマスターメッセージは同じ順序で届きますか？そうでない場合は、エンリッチメントをマスターメッセージに一致させるための何らかのIDがあると思います
3. マスターメッセージは遅延しない可能性があり、到着時にプッシュスルーする必要があるようです。では、エンリッチメントメッセージはマスターメッセージにどのように適用されますか？マスター+エンリッチメントという新しいメッセージをプッシュしますか？状態を変更したくない、つまり、転送された後にマスターメッセージを変更したくないと思います。

Answer 2

このような状況で使用することをお勧めしますReplaySubject。ここで実用的なサンプルを見つけることができます：別のIObservableが公開されるまで、IObservableをサブスクライブするが、そこからデータをバッファリングする方法は？。そのコードは私にとって素晴らしい働きをします。