ObserveOnObserverNew<T> sealed class ObserveOnObserverNew<T> : IdentitySink<T> Documentation Code public ObserveOnObserverNew(IScheduler scheduler, IObserver<T> downstream)