BatchingAsyncIterator<TInput>

Namespace: SnowBank.Linq.Async.Iterators · class

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

Packs items from an inner sequence, into a sequence of fixed-size arrays.

Constructors

BatchingAsyncIterator<TInput>

BatchingAsyncIterator<TInput>(IAsyncQuery<TInput> source, int batchSize)

Create a new batching iterator

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