Rx中的HistoricalScheduler

Question

我有以下代碼，我嘗試重播序列;但PostWorkItem始終爲空;我不明白爲什麼。 下面的代碼給出堆棧溢出錯誤。

 Task<List<WorkItem>> WorkItems = DbUtil.GetWorkItems(new List<string>() { WorkItemStatus.NEW, WorkItemStatus.PROCESSING }); 
     Items = WorkItems.Result; 

     replay = Observable.Generate(
       Items.GetEnumerator(), 
       events => events.MoveNext(), 
       events => events, 
       events => events.Current, 
       events => System.TimeSpan.FromMilliseconds(50), 
        var); 

     replay.Subscribe(
      W => 
       PostWorkItem(W) 
      ); 

     //var.AdvanceBy(System.TimeSpan.FromSeconds(1)); 

     var.Start(); 

Answer 1

您需要Observable.Generate指定類型參數明確，這樣它不會混淆的非通用的IEnumerator。嘗試更換您的第三行代碼：

replay = Observable.Generate<IEnumerator<WorkItem>,WorkItem>(