Rx.Net TestScheduler如何重放事件？

Question

我正在尝试理解如何在c#中实现以下功能

我有一份这个课程的清单

public class StockTickerChangeHistory
{
    public DateTime Time;
    public string Stock;
}

我想创建一个在OnNext成员变量指定的时间触发time的观察值。我知道TestScheduler附带了Rx.Net，但我不知道如何在我现有的结构中使用它。

我已经阅读了这篇文章，但不确定如何将其转换为c#，因为它似乎完全符合我的需要。

https://blog.niallconnaughton.com/2015/05/09/time-travel-with-reactive-extensions/

任何帮助都将不胜感激。罗恩。

Answer 1

假设stocks是由Time订购的IEnumerable<StockTickerChangeHistory>

var scheduler = new TestScheduler();

//Convert to array of OnNext notifications and create an Observable
var history = stocks.Select(i => OnNext(i.Time.Ticks, i)).ToArray();
var stockHistoryObservable = scheduler.CreateHotObservable(history);

//Create an observer and subscribe
var observer = scheduler.CreateObserver<StockTickerChangeHistory>();
stockHistoryObservable.Subscribe(observer);

scheduler.AdvanceTo(dateWhenNoHistoryYet); //no history
observer.Messages.AssertEqual(); 
scheduler.AdvanceTo(dateWhenHistoryIsCompleted); //all history arrived
observer.Messages.AssertEqual(history);