.NET Reactive框架：ReplaySubject OnError：它为什么会抛出异常？

Question

注：我指的是.NET 4版本的RX。

我一直在使用RX的ReplaySubject类。我将OnError作为参数调用异常。

我在期待它会通知所有的OnError订阅者，并将它们传递给它的异常，相反它只是引发异常，之后异常只是未处理。代码很简单，你可以看看GitHub上的代码。 https://github.com/arielbh/CodeCommander/blob/master/CodeValue.CodeCommander/CommandBase.cs 117号线是OnNext呼叫。

有什么想法吗？显然我希望我期望发生的行为。 感谢

阿里尔

Answer 1

OK，我发现它的原因。 如果您未订阅OnError，则默认行为是抛出异常。 我不够小心，所以引发错误的主题没有被观察到。

更多信息： http://social.msdn.microsoft.com/Forums/en/rx/thread/3125094b-1ab2-4d01-8f44-fb68ef913f43

Answer 2

我打这个奇怪的行为了。我创建了自己的扩展方法来获得我期待的行为。

public static void SendOnError<T, E>(this IObserver<T> Subject, E ExceptionToSend) where E : Exception 
    { 
     try { Subject?.OnError(ExceptionToSend); } 
     catch (E exception) 
     { 
      Debug.WriteLine("One or more subscribers to the subject did not implement an OnError handler. Ignoring rethrown exception: " + exception.Message); 
     } 
    }