c# - .Net 响应式扩展 : Remove Replay

Question

在下面的代码中，我使用 Replay() 来避免在执行 stuff [...] 时价格更新丢失。我需要在 stuff[...] 完成后发送这些价格更新。

var observable = Observable.FromEventPattern<Price>(h => book.PriceUpdated += h, h => book.PriceUpdated -= h)
                           .Replay();
observable.Connect();

// Do some stuff [...]

observable.Select(p => Observable.FromAsync(() => SendPriceUpdateAsync(p.Sender, p.EventArgs, socket)))
                      .Concat()
                      .Subscribe();

我想在 stuff [...] 完成并发送价格后删除 Replay()(我不希望所有值都是已存储，发送后我不再需要这些值)。

有什么简单的方法吗？

Answer 1

所以您真正想要的是延迟所有事件，直到您完成做一些事情。我建议根本不要使用 Replay。

改为尝试这样的方法:

var observable = eventObservable
.TakeUntil(Observable.Start(() => { /* Do some stuff [...] */ })) //collect only events while processing, completes the observable when done processing
.ToList() //with ToList only propagate all at once on completion
.SelectMany(list => list.ToObservable()) //unfold the list to single events again
.Concat(eventObservable); //continue with normal events observable