Sink<TTarget> abstract class Sink<TTarget> : ISink<TTarget>, IDisposable Documentation Code protected Sink(IObserver<TTarget> observer) public void Dispose() protected virtual void Dispose(bool disposing) protected void DisposeUpstream() public void ForwardOnCompleted() public void ForwardOnError(Exception error) public void ForwardOnNext(TTarget value) protected void SetUpstream(IDisposable upstream)