Type Members

1.  class ExtractMaterializedValue[T, Mat] extends GraphStageWithMaterializedValue[FlowShape[T, T], Future[Mat]]

   Takes the input data, applies the provided transformation function, and completes its materialized value with it.

2.  final case class ImmutableIterable[T](iterable: Iterable[T]) extends Iterable[T] with Product with Serializable

   Added to make pekko-streams .mapConcat accept collections parsed from proto.

3.  class MaxInFlight[I, O] extends GraphStage[BidiShape[I, I, O, O]]

   Enforces that at most maxInFlight items traverse the flow underneath this one.

   Enforces that at most maxInFlight items traverse the flow underneath this one. Requires the flow underneath to always produce 1 output element for 1 input element in order to work correctly. With respect to completion, failure and cancellation, the input and output stream behave like normal Flows, except that if the output stream is failed, cancelled or completed, the input stream is completed.