lazySource

Defers creation and materialization of a Source until there is demand.

Source operators

Signature

def lazySource[T, M](create: () => Source[T, M]): Source[T, Future[M]]

Description

Defers creation and materialization of a Source until there is demand, then emits the elements from the source downstream just like if it had been created up front.

See also lazyFutureSource.

Note that asynchronous boundaries (and other operators) in the stream may do pre-fetching which counter acts the laziness and will trigger the factory immediately.

Reactive Streams semantics

emits depends on the wrapped Source

completes depends on the wrapped Source

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.