Sink.lazyInitAsync
Deprecated by Sink.lazyFutureSink
.
Signature
Flow.lazyInitAsync
Flow.lazyInitAsync
Sink.lazyInitAsync
Sink.lazyInitAsync
Description
lazyInitAsync
has been deprecated in 2.6.0, 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
Future
CompletionStage
is completed withNone
an emptyOptional
. - If upstream fails before an element was received,
sinkFactory
throws an exception, or materialization of the internal sink fails then theFuture
CompletionStage
is completed with the exception. - Otherwise the
Future
CompletionStage
is completed with the materialized value of the internal sink.
Reactive Streams semantics
cancels never
backpressures when initialized and when created sink backpressures