ObserveOnObserver<T> sealed class ObserveOnObserver<T> : ScheduledObserver<T> Documentation Code public ObserveOnObserver(IScheduler scheduler, IObserver<T> observer) public void Run(IObservable<T> source)