RX.Net：使用重试但记录任何异常

Question

我是RX的新手，一直在研究错误处理和Retry的使用;我有以下内容（是的，我知道这不是一个'真正的'单元测试，但它让我可以摆弄！），并想知道如何去保持重试但能够记录任何异常？

[Test] 
    public void Test() 
    { 
     var scheduler = new TestScheduler(); 

     var source = scheduler.CreateHotObservable(
      new Recorded<Notification<long>>(10000000, Notification.CreateOnNext(0L)), 
      new Recorded<Notification<long>>(20000000, Notification.CreateOnNext(1L)), 
      new Recorded<Notification<long>>(30000000, Notification.CreateOnNext(2L)), 
      new Recorded<Notification<long>>(30000001, Notification.CreateOnError<long>(new Exception("Fail"))), 
      new Recorded<Notification<long>>(40000000, Notification.CreateOnNext(3L)), 
      new Recorded<Notification<long>>(40000000, Notification.CreateOnCompleted<long>()) 
     ); 

     source.Retry().Subscribe(
      l => Console.WriteLine($"OnNext {l}"), 
      exception => Console.WriteLine(exception.ToString()), // Would be logging this in production 
      () => Console.WriteLine("OnCompleted")); 

     scheduler.Start(
      () => source, 
      0, 
      TimeSpan.FromSeconds(1).Ticks, 
      TimeSpan.FromSeconds(5).Ticks); 
    } 

导致...

OnNext 0 
OnNext 1 
OnNext 2 
OnNext 3 
OnCompleted 

...这正是我想要离开的事实发生，我想记录发生2和3之间

异常

有没有办法允许订阅者在OnError中看到异常（并记录下来），然后重新订阅，以便看到3？

Thx！

Answer 1

你可以实现与此：

source 
    .Do(_ => { }, exception => Console.WriteLine(exception.ToString()),() => {}) 
    .Retry() 
    .Subscribe(
     l => Console.WriteLine($"OnNext {l}"), 
     //  exception => Console.WriteLine(exception.ToString()), // Would be logging this in production 
     () => Console.WriteLine("OnCompleted") 
    ); 

只是为了澄清这是怎么回事就在这里：OnError是终止信号。如果错误达到了订阅，那会终止流的其余部分。 .Retry终止订阅，吞下OnError，然后重新订阅，将两个订阅合并在一起。例如看看这个：

source 
    .StartWith(-1) 
    .Retry() 
    .Subscribe(
     l => Console.WriteLine($"OnNext {l}"), 
     () => Console.WriteLine("OnCompleted") 
    ); 

你的产出将是

OnNext -1 
OnNext 0 
OnNext 1 
OnNext 2 
OnNext -1 
OnNext 3 
OnCompleted 

的OnNext -1显示了两次，因为它表明，每当您订阅（该OnError

之后Retry贵。测试可观察性是一个不好的测试，它打破了“Rx合约”，即通知遵循以下模式：

OnNext* (OnCompleted | OnError)? 

也就是说，0或更多OnNext通知，然后是可选OnError或可选OnCompleted。任何类型的通知都不应跟随OnError或OnCompleted。