System.Reactive.Sink<TTarget>

abstract class Sink<TTarget> : ISink<TTarget>, IDisposable

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 ForwardOnNext(TTarget value)

protected void SetUpstream(IDisposable upstream)