.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); 
     } 
    }