AsyncForEachAsyncState()

System.Threading.Tasks.Parallel.AsyncForEachAsyncState< TSource >.AsyncForEachAsyncState ( IAsyncEnumerable< TSource > source, Func< object, Task > taskBody, int dop, TaskScheduler scheduler, CancellationToken cancellationToken, Func< TSource, CancellationToken, ValueTask > body )

inline

Definition at line 133 of file Parallel.cs.

            : base(taskBody, dop, scheduler, cancellationToken, body)
        {
            Enumerator = source.GetAsyncEnumerator(Cancellation.Token) ?? throw new InvalidOperationException(System.SR.Parallel_ForEach_NullEnumerator);
        }

References System.Threading.Tasks.Parallel.ForEachAsyncState< TSource >.Cancellation, System.Threading.Tasks.Parallel.AsyncForEachAsyncState< TSource >.Enumerator, System.SR.Parallel_ForEach_NullEnumerator, System.source, and System.Threading.CancellationTokenSource.Token.