// Licensed to the .NET Foundation under one or more agreements. // The .NET Foundation licenses this file to you under the Apache 2.0 License. // See the LICENSE file in the project root for more information. using System.Collections.Generic; using System.Threading; using System.Threading.Tasks; namespace System.Linq { public static partial class AsyncEnumerable { public static Task ForEachAsync(this IAsyncEnumerable source, Action action) { if (source == null) throw new ArgumentNullException(nameof(source)); if (action == null) throw new ArgumentNullException(nameof(action)); return ForEachAsync(source, action, CancellationToken.None); } public static Task ForEachAsync(this IAsyncEnumerable source, Action action) { if (source == null) throw new ArgumentNullException(nameof(source)); if (action == null) throw new ArgumentNullException(nameof(action)); return ForEachAsync(source, action, CancellationToken.None); } public static Task ForEachAsync(this IAsyncEnumerable source, Action action, CancellationToken cancellationToken) { if (source == null) throw new ArgumentNullException(nameof(source)); if (action == null) throw new ArgumentNullException(nameof(action)); return source.ForEachAsync((x, i) => action(x), cancellationToken); } public static Task ForEachAsync(this IAsyncEnumerable source, Action action, CancellationToken cancellationToken) { if (source == null) throw new ArgumentNullException(nameof(source)); if (action == null) throw new ArgumentNullException(nameof(action)); return ForEachAsyncCore(source, action, cancellationToken); } public static Task ForEachAsync(this IAsyncEnumerable source, Func action) { if (source == null) throw new ArgumentNullException(nameof(source)); if (action == null) throw new ArgumentNullException(nameof(action)); return ForEachAsync(source, action, CancellationToken.None); } public static Task ForEachAsync(this IAsyncEnumerable source, Func action) { if (source == null) throw new ArgumentNullException(nameof(source)); if (action == null) throw new ArgumentNullException(nameof(action)); return ForEachAsync(source, action, CancellationToken.None); } public static Task ForEachAsync(this IAsyncEnumerable source, Func action, CancellationToken cancellationToken) { if (source == null) throw new ArgumentNullException(nameof(source)); if (action == null) throw new ArgumentNullException(nameof(action)); return source.ForEachAsync((x, i, ct) => action(x), cancellationToken); } public static Task ForEachAsync(this IAsyncEnumerable source, Func action, CancellationToken cancellationToken) { if (source == null) throw new ArgumentNullException(nameof(source)); if (action == null) throw new ArgumentNullException(nameof(action)); return source.ForEachAsync((x, i, ct) => action(x, ct), cancellationToken); } public static Task ForEachAsync(this IAsyncEnumerable source, Func action, CancellationToken cancellationToken) { if (source == null) throw new ArgumentNullException(nameof(source)); if (action == null) throw new ArgumentNullException(nameof(action)); return source.ForEachAsync((x, i, ct) => action(x, i), cancellationToken); } public static Task ForEachAsync(this IAsyncEnumerable source, Func action, CancellationToken cancellationToken) { if (source == null) throw new ArgumentNullException(nameof(source)); if (action == null) throw new ArgumentNullException(nameof(action)); return ForEachAsyncCore(source, action, cancellationToken); } private static async Task ForEachAsyncCore(IAsyncEnumerable source, Action action, CancellationToken cancellationToken) { var index = 0; var e = source.GetAsyncEnumerator(); try { while (await e.MoveNextAsync(cancellationToken).ConfigureAwait(false)) { action(e.Current, checked(index++)); } } finally { await e.DisposeAsync().ConfigureAwait(false); } } private static async Task ForEachAsyncCore(IAsyncEnumerable source, Func action, CancellationToken cancellationToken) { var index = 0; var e = source.GetAsyncEnumerator(); try { while (await e.MoveNextAsync(cancellationToken).ConfigureAwait(false)) { await action(e.Current, checked(index++), cancellationToken).ConfigureAwait(false); } } finally { await e.DisposeAsync().ConfigureAwait(false); } } } }