.NET Reactive framework：ReplaySubject OnError：なぜ例外がスローされるのですか？

Question

注：私はRXの.NET 4バージョンを指しています。

私は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); 
     } 
    }