ObserveOnObserverLongRunning<TSource> sealed class ObserveOnObserverLongRunning<TSource> : IdentitySink<TSource> Signals events on a ISchedulerLongRunning by blocking the emission thread while waiting for them from the upstream. Documentation Code public ObserveOnObserverLongRunning(ISchedulerLongRunning scheduler, IObserver<TSource> observer)