<PackageReference Include="AsyncEnumerator" Version="2.1.0" />

System.Collections.Async.ForEachAsyncExtensions

public static class ForEachAsyncExtensions
Enables asynchronous 'foreach' enumeration over an IAsyncEnumerable
namespace System.Collections.Async { public static class ForEachAsyncExtensions { public static async Task ForEachAsync(this IAsyncEnumerable enumerable, Action<object> action, CancellationToken cancellationToken = default(CancellationToken)); public static async Task ForEachAsync(this IAsyncEnumerator enumerator, Action<object> action, CancellationToken cancellationToken = default(CancellationToken)); public static async Task ForEachAsync(this IAsyncEnumerable enumerable, Action<object, long> action, CancellationToken cancellationToken = default(CancellationToken)); public static async Task ForEachAsync(this IAsyncEnumerator enumerator, Action<object, long> action, CancellationToken cancellationToken = default(CancellationToken)); public static async Task ForEachAsync(this IAsyncEnumerable enumerable, Func<object, Task> action, CancellationToken cancellationToken = default(CancellationToken)); public static async Task ForEachAsync(this IAsyncEnumerator enumerator, Func<object, Task> action, CancellationToken cancellationToken = default(CancellationToken)); public static async Task ForEachAsync(this IAsyncEnumerable enumerable, Func<object, long, Task> action, CancellationToken cancellationToken = default(CancellationToken)); public static async Task ForEachAsync(this IAsyncEnumerator enumerator, Func<object, long, Task> action, CancellationToken cancellationToken = default(CancellationToken)); public static async Task ForEachAsync<T>(this IAsyncEnumerable<T> enumerable, Action<T> action, CancellationToken cancellationToken = default(CancellationToken)); public static async Task ForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Action<T> action, CancellationToken cancellationToken = default(CancellationToken)); public static async Task ForEachAsync<T>(this IAsyncEnumerable<T> enumerable, Action<T, long> action, CancellationToken cancellationToken = default(CancellationToken)); public static async Task ForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Action<T, long> action, CancellationToken cancellationToken = default(CancellationToken)); public static async Task ForEachAsync<T>(this IAsyncEnumerable<T> enumerable, Func<T, Task> action, CancellationToken cancellationToken = default(CancellationToken)); public static async Task ForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, Task> action, CancellationToken cancellationToken = default(CancellationToken)); public static async Task ForEachAsync<T>(this IAsyncEnumerable<T> enumerable, Func<T, long, Task> action, CancellationToken cancellationToken = default(CancellationToken)); public static async Task ForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, long, Task> action, CancellationToken cancellationToken = default(CancellationToken)); } }