.NET ReactiveExtension观察者未捕获OnError中的错误

Question

使用ReactiveExtension时,onError操作不会捕获异常.使用下面的示例代码而不是捕获的异常"在System.Reactive.Core.dll中发生未处理的类型'System.ApplicationException'异常"并且应用程序终止.异常似乎绕过了调用堆栈中的每个try/catch.

var source = Observable.Interval(TimeSpan.FromSeconds(seconds));
var observer = Observer.Create<long>(
    l =>
    { 
       //do something
       throw new ApplicationException("test exception");
    },
    ex => Console.WriteLine(ex));
var subscription = source.Subscribe(observer);

我错过了观察者应该如何处理异常？

如果我在onNext操作中放入try catch,则会捕获异常并且我可以记录它.

var source = Observable.Interval(TimeSpan.FromSeconds(seconds));
var observer = Observer.Create<long>(
    l =>
    { 
       try
       {
         //do something
         throw new ApplicationException("test exception");
       }
       catch(Exception ex)
       {
          //exception can be caught here and logged
          Console.WriteLine(ex);
       }
    },
    ex => Console.WriteLine(ex));
var subscription = source.Subscribe(observer);

如何通过onError操作捕获异常需要做什么？

Answer 1

只有在可观察量中出现异常时才会捕获异常.如果他们在观察者中长大,那么你必须亲自抓住他们.

这有道理,原因有很多:

1. 如果你有几个观察者附加到一个热观察者,那么你不希望流被终止,因为其中一个观察者做错了什么.
2. 你不希望其他观察者知道其他观察者的运作方式
3. 如果在一个观察者之后抛出异常,而另一个观察者成功处理了一个值,但在下一个观察到它之前,你可能最终处于一个不一致的状态.