For Each (Parallel)

Concurrency

flow.forEachParallelRuns the body for every element of a collection in parallel, capped at 'maxDegreeOfParallelism' concurrent items (0 = unbounded). Failure-safe: one item's error is logged and the rest continue.Bounded parallel-foreach over a collection, failure-safe.

Inputs

Name	Kind	Type	Flags
in	Exec	exec	multiplexed
source	Data	any	None

Outputs

Name	Kind	Type	Flags
body	Exec	exec	None
item	Data	any	multiplexed
completed	Exec	exec	None

Parameters

Name	Type	Required	Default	Choices
maxDegreeOfParallelism	System.Int32	no	4	None

Lowers to C#

await Parallel.ForEachAsync(source, new() { MaxDegreeOfParallelism = n }, async (item, ct) => { /* body */ });

Used in

Shout out every live teammate in parallel (Example)