BaseBlocking<T> abstract class BaseBlocking<T> : CountdownEvent, IObserver<T> Documentation Code protected IDisposable _upstream public void Dispose() public abstract void OnCompleted() public virtual void OnError(Exception error) public abstract void OnNext(T value) protected void Unblock()