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) Override this method to dispose additional resources. The method is guaranteed to be called at most once. protected void DisposeUpstream() public void ForwardOnCompleted() public void ForwardOnError(Exception error) public void ForwardOnNext(TTarget value) protected void SetUpstream(IDisposable upstream)