これは .Synchronize() が必要ですか? そうでない場合、実際に使用する必要があるのはいつですか?
_subject.SubscribeOn(Scheduler.TaskPool).ObserveOn(SynchronizationContext.Current).Synchronize().Subscribe(OnNext)
これが必要かもしれないと思った理由は、サブジェクトの OnNext を複数のスレッドから呼び出しているからです。ただし、メイン スレッドで OnNext メソッドを実行する必要があります。