Dasync.Collections.ForEachAsyncExtensions
Enables asynchronous 'foreach' enumeration over an IAsyncEnumerable
namespace Dasync.Collections
{
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);
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);
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);
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);
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);
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);
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);
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);
}
}