BaseBlocking<T> abstract class BaseBlocking<T> : ManualResetEventSlim, IObserver<T> Documentation Code public void OnCompleted() public void OnError(Exception error) public abstract void OnNext(T value)