Flow.lazyInitAsync

Deprecated by Flow.lazyFutureFlow in combination with prefixAndTail.

Simple operators

Signature

Flow.lazyInitAsyncFlow.lazyInitAsync

Description

fromCompletionStage has been deprecated in 2.6.0 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 behaviour in case of downstream cancellation before nested flow materialization (future completion) is to cancel immediately. This behaviour can be controlled by setting the akka.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).

Found an error in this documentation? The source code for this page can be found here. Please feel free to edit and contribute a pull request.