PushToPullSink<TSource, TResult> abstract class PushToPullSink<TSource, TResult> : IObserver<TSource>, IEnumerator<TResult>, IEnumerator, IDisposable Documentation Code public TResult Current { get; } protected PushToPullSink() 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 void SetUpstream(IDisposable d) public abstract bool TryMoveNext(out TResult current)