.net - 使用 Rx 同步两个流

Question

我有一个来自主源的数据流，第二个流包含来自不同来源的丰富数据。不幸的是，丰富消息通常在原始数据之前到达。我想确保在原始消息首次发布之前缓冲丰富消息。我可以通过 Rx 实现这一目标吗？

Answer 1

简短的回答，可能。正如@Enigmativity 也没有提及，这是一个有点开放式的问题。

1. 是否有一对一的消息（显然没有 - '可能没有丰富值'）
2. 扩充消息和主消息是否以相同的顺序到达。如果不是，那么我假设有某种 Id 可以将丰富内容与主消息相匹配
3. 似乎主消息可能不会延迟，并且必须在到达时推送。那么如何将丰富消息应用于主消息？我们是否推送了一个新信息，即大师+浓缩？我假设您不想改变状态，即在转发后修改主消息。

Answer 2

我建议你ReplaySubject在这种情况下使用。您可以在此处找到工作示例：How to subscribe to but buffer data from, an IObservable until another IObservable has published？. 该代码对我很有用。