AsyncIteratorPump<TInput>

Namespace: SnowBank.Linq.Async.Iterators · class

Pump that repeatedly calls MoveNext on an iterator and tries to publish the values in a Producer/Consumer queue

Constructors

AsyncIteratorPump<TInput>(IAsyncEnumerator<TInput> iterator, IAsyncTarget<TInput> target)

bool IsCompleted { get; }

Returns true if the pump has completed (with success or failure)

Task PumpAsync(CancellationToken ct)

Run the pump until the inner iterator is done, an error occurs, or the cancellation token is fired