Sink<TSource> abstract class Sink<TSource> : IDisposable Documentation Code public Sink(IObserver<TSource> observer, IDisposable cancel) public virtual void Dispose() public IObserver<TSource> GetForwarder()