pkg
Chris-Wolfgang/Wolfgang.Extensions.IAsyncEnumerablev0.1.0
.NET FW4.6.2.NET 8.0.NET 10.0.NET Std2.0
A collection of extension methods for IAsyncEnumerable
Get Started
$ dotnet add package Wolfgang.Extensions.IAsyncEnumerableReadme
Wolfgang.Extensions.IAsyncEnumerable
High-performance, production-grade extension methods for IAsyncEnumerable<T> with comprehensive test coverage and strict code quality enforcement.
📦 Installation
dotnet add package Wolfgang.Extensions.IAsyncEnumerable
NuGet Package: Coming soon to NuGet.org
🚀 Quick Start
using Wolfgang.Extensions.IAsyncEnumerable;
// Chunk an async stream into batches
await foreach (var chunk in asyncStream.ChunkAsync(maxChunkSize: 100, token: cancellationToken))
{
// Process each chunk (ICollection<T>)
await ProcessBatchAsync(chunk);
}
✨ Features
Current Extension Methods
ChunkAsync<T>
Splits an IAsyncEnumerable<T> into fixed-size chunks for batch processing.
public static async IAsyncEnumerable<ICollection<T>> ChunkAsync<T>(
this IAsyncEnumerable<T> source,
int maxChunkSize,
CancellationToken token = default)
Parameters:
source- The source async enumerable to chunkmaxChunkSize- Maximum size of each chunk (must be > 0)token- Optional cancellation token
Returns: An async enumerable of collections, where each collection contains up to maxChunkSize elements.
Example:
var numbers = GetAsyncNumbers(); // IAsyncEnumerable<int>
await foreach (var batch in numbers.ChunkAsync(50))
{
Console.WriteLine($"Processing batch of {batch.Count} items");
// Last batch may be smaller than 50
}