TailRecursiveSink<TSource> abstract class TailRecursiveSink<TSource> : Sink<TSource>, IObserver<TSource> Documentation Code protected Action _recurse public TailRecursiveSink(IObserver<TSource> observer, IDisposable cancel) protected virtual void Done() protected abstract IEnumerable<IObservable<TSource>> Extract(IObservable<TSource> source) protected virtual bool Fail(Exception error) public abstract void OnCompleted() public abstract void OnError(Exception error) public abstract void OnNext(TSource value) public IDisposable Run(IEnumerable<IObservable<TSource>> sources)