Sink.foreachAsync

Invoke a given procedure asynchronously for each element received.

Sink operators

Signature¶

Sink.foreachAsyncSink.foreachAsync

Description¶

Invoke a given procedure asynchronously for each element received. Note that if shared state is mutated from the procedure that must be done in a thread-safe way.

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

See also:

• foreach Invoke a given procedure for each element received.
• actorRef Send the elements from the stream to an ActorRef.

Example¶

Scala

Java

copysource// def asyncProcessing(value: Int): Future[Unit] = _

Source(1 to 100).runWith(Sink.foreachAsync(10)(asyncProcessing))

copysource// final Function<Integer, CompletionStage<Void>> asyncProcessing = _

final Source<Integer, NotUsed> numberSource = Source.range(1, 100);

numberSource.runWith(Sink.foreachAsync(10, asyncProcessing), system);

Reactive Streams semantics¶