foreach

Invoke a given procedure for each element received.

Sink operators

def foreach[T](f: T => Unit): Sink[T, Future[Done]]

Description

Invoke a given procedure for each element received. Note that it is not safe to mutate shared state from the procedure.

The sink materializes into a Future[Option[Done]] CompletionStage<Optional<Done> which completes when the stream completes, or fails if the stream fails.

Note that it is not safe to mutate state from the procedure.