WindowingAsyncIterator<TInput>

Namespace: SnowBank.Linq.Async.Iterators · class

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

Merges bursts of already-completed items from a source async sequence, into a sequence of batches.

Constructors

WindowingAsyncIterator<TInput>

WindowingAsyncIterator<TInput>(IAsyncQuery<TInput> source, int maxWindowSize)

Create a new batching iterator

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