無擴展方法來熱觀察的時間間隔轉換爲冷觀察到

Question

可以說我有這個炎熱的觀察到一個發佈連續數每秒5分鐘：

1，2，...，N，OnCompleted

在某個時間點，在熱點觀察點開始後，但在它完成之前，我訂閱它直到它完成。

我得到數字：x，x + 1，x + 2，... n。

我想將收到的值轉換爲冷觀察值。 有沒有特殊的操作符？

我知道我可以只使用

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

但我敢肯定有一個的Rx擴展方法我失去了，這不只是

Answer 1

只需使用重播主題。

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