TailRecursiveSink<TSource> abstract class TailRecursiveSink<TSource> : IdentitySink<TSource> Documentation Code protected TailRecursiveSink(IObserver<TSource> observer) protected virtual void Done() protected abstract IEnumerable<IObservable<TSource>> Extract(IObservable<TSource> source) protected virtual bool Fail(Exception error) protected void Recurse() public void Run(IEnumerable<IObservable<TSource>> sources)