Sink.lazyInitAsync

Deprecated by Sink.lazyFutureSink.

Sink operators

Signature

Flow.lazyInitAsyncFlow.lazyInitAsync Sink.lazyInitAsyncSink.lazyInitAsync

Description

lazyInitAsync is deprecated, please use lazyFutureSink instead.

Creates a real Sink upon receiving the first element. Internal Sink will not be created if there are no elements, because of completion or error.

• If upstream completes before an element was received then the FutureCompletionStage is completed with Nonean empty Optional.
• If upstream fails before an element was received, sinkFactory throws an exception, or materialization of the internal sink fails then the FutureCompletionStage is completed with the exception.
• Otherwise the FutureCompletionStage is completed with the materialized value of the internal sink.

Reactive Streams semantics