使用Rx同步兩個流

Question

我有一個來自主源的數據流，第二個流來自不同來源的富集數據。不幸的是，富集信息通常在原始數據之前到達。我想確保富文本消息被緩存，直到原始消息首次發佈。我可以用Rx來實現嗎？

Answer 1

簡短的回答，可能。由於@Enigmativity也避而遠之，這是一個有點開放式的問題。

1. 是否有1對1的消息（顯然不是 - 「有可能不是一個富集值」）
2. 的豐富信息和掌握的消息將在同一順序到達。如果不是，那麼我假設有某種類型的編號可以將主要消息的內容與主題相匹配
3. 似乎主消息可能不會被延遲，並且必須在到達時通過。那麼豐富消息如何應用於主消息？我們是否推出了一個新的信息，即主+豐富？我假設你不想改變狀態，即在主消息被轉發之後修改主消息。

Answer 2

我建議你在這種情況下使用ReplaySubject。您可以在這裏找到工作示例：How to subscribe to, but buffer data from, an IObservable until another IObservable has published?。該代碼對我很有用。