A SinkTIn, TMat that will invoke the given action to each of the elements as they pass in. The sink is materialized into a Task. If the action throws an exception and the supervision decision is Stop the Task will be completed with failure. If the action throws an exception and the supervision decision is Resume or Restart the element is dropped and the stream continues.

See also

public static Sink<TIn, Task> ForEachParallel<TIn>(
	int parallelism,
	Action<TIn> action
)

static member ForEachParallel : 
        parallelism : int * 
        action : Action<'TIn> -> Sink<'TIn, Task>