<PackageReference Include="System.Reactive" Version="6.1.0-preview.9" />

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.
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)