.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

好的，我找到了原因。
如果您没有订阅 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);
        }
    }