PushToPullSink<TSource, TResult> abstract class PushToPullSink<TSource, TResult> : IObserver<TSource>, IEnumerator<TResult>, IEnumerator, IDisposable Documentation Code public TResult Current { get; } public PushToPullSink(IDisposable subscription) public void Dispose() public bool MoveNext() public abstract void OnCompleted() public abstract void OnError(Exception error) public abstract void OnNext(TSource value) public void Reset() public abstract bool TryMoveNext(out TResult current)