PrefetchingAsyncIterator<TInput>

Namespace: SnowBank.Linq.Async.Iterators · class

Implements: AsyncFilterIterator<TInput, TInput>, IAsyncLinqQuery<TInput>, IAsyncQuery<TInput>, IAsyncEnumerable<TInput>, IAsyncEnumerator<TInput>, IAsyncDisposable

Prefetches items from the inner sequence, before outputting them down the line.

Constructors

PrefetchingAsyncIterator<TInput>

PrefetchingAsyncIterator<TInput>(IAsyncQuery<TInput> source, int prefetchCount)

Create a new batching iterator

  • source — Source sequence of items that must be batched by waves
  • prefetchCount — Maximum size of a batch to return down the line