Flow.lazyInitAsync
Deprecated by Flow.lazyFutureFlow in combination with prefixAndTail.
Signature
Flow.lazyInitAsyncFlow.lazyInitAsync
Description
fromCompletionStage is deprecated, please use lazyFutureFlow in combination with prefixAndTail) instead.
Defers creation until a first element arrives.
Reactive Streams semantics
emits when the internal flow is successfully created and it emits
backpressures when the internal flow is successfully created and it backpressures
completes when upstream completes and all elements have been emitted from the internal flow
completes when upstream completes and all futures have been completed and all elements have been emitted
cancels when downstream cancels (keep reading) The operator’s default behavior in case of downstream cancellation before nested flow materialization (future completion) is to cancel immediately. This behavior can be controlled by setting the org.apache.pekko.stream.Attributes.NestedMaterializationCancellationPolicy.PropagateToNested attribute, this will delay downstream cancellation until nested flow’s materialization which is then immediately cancelled (with the original cancellation cause).