ObserveOnObserverLongRunning<TSource> sealed class ObserveOnObserverLongRunning<TSource> : IdentitySink<TSource> Documentation Code public ObserveOnObserverLongRunning(ISchedulerLongRunning scheduler, IObserver<TSource> observer)