Sink<TSource, TTarget> abstract class Sink<TSource, TTarget> : Sink<TTarget>, IObserver<TSource> Base class for implementation of query operators, providing a lightweight sink that can be disposed to mute the outgoing observer. Documentation Code protected Sink(IObserver<TTarget> observer) public IObserver<TTarget> GetForwarder() public virtual void OnCompleted() public virtual void OnError(Exception error) public abstract void OnNext(TSource value) public virtual void Run(IObservable<TSource> source)