使用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?。该代码对我很有用。