Source/Flow.setup

Defer the creation of a Source/Flow until materialization and access ActorMaterializer and Attributes

Simple operators

Signature

def setup[T, M](factory: (ActorMaterializer, Attributes) ⇒ Source[T, M]): Source[T, Future[M]]
def setup[T, U, M](factory: (ActorMaterializer, Attributes) ⇒ Flow[T, U, M]): Flow[T, U, Future[M]]

Description

Typically used when access to materializer is needed to run a different stream during the construction of a source/flow. Can also be used to access the underlying ActorSystem from ActorMaterializer.

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.