Strategy that defines how a stream of streams should be flattened into a stream of simple elements.
A FlowMaterializer takes the list of transformations comprising a akka.stream.scaladsl.Flow and materializes them in the form of org.reactivestreams.api.Processor instances.
The buffers employed by the generated Processors can be configured by creating an appropriate instance of this class.
Represents a strategy that decides how to deal with a buffer that is full but is about to receive a new element.
Transformer with support for scheduling keyed (named) timer events.
General interface for stream transformation.
This exception must be thrown from a callback-based stream producer to signal the end of stream (if the produced stream is not infinite).