c# - 将热可观察区间转换为冷可观察区间的响应式(Reactive)扩展方法

Question

比方说我有一个热的可观察对象，它每秒发布连续的数字，持续 5 分钟:

1, 2, ... n, 完成

在某个时间点，在热 observable 开始之后，但在它完成之前，我订阅它直到它完成。

我得到数字:x, x+1, x+2, ... n。

我想将收到的值转换为冷可观察值。有专门的运算符(operator)吗？

我知道我可以用

Observable.Create(observer => hotObservable.Subscribe(onNext, onCompleted, onError);

但我确定我缺少一个 Rx 扩展方法，它就是这样做的

Answer 1

只需使用 Replay Subject。

ReplaySubject<int> sub = new ReplaySubject<int>();
hotObservable.Subscribe(sub);
//Now any one can subscribe to sub and it will get all items that hot observable sent to replay subject