Sink.eagerFutureSink

Materializes the inner sink when the future completes, even if no elements have arrived yet.

Sink operators

Signature

Sink.eagerFutureSinkSink.eagerFutureSink

Description

Turn a Future[Sink] into a Sink that will consume the values of the source when the future completes successfully. If the Future is completed with a failure the stream is failed.

Unlike futureSink and lazyFutureSink, this operator materializes the inner sink as soon as the future completes, even if no elements have arrived yet. This means empty streams complete normally rather than failing with NeverMaterializedException. At most one element that arrives before the future completes is buffered.

The materialized future value is completed with the materialized value of the inner sink once it has been materialized, or failed if the future itself fails or if materialization of the inner sink fails. Upstream failures or downstream cancellations that occur before the inner sink is materialized are propagated through the inner sink rather than failing the materialized value directly.

See also futureSink, lazyFutureSink.

Reactive Streams semantics