class MaxInFlight[I, O] extends GraphStage[BidiShape[I, I, O, O]]
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.
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- MaxInFlight
- GraphStage
- GraphStageWithMaterializedValue
- Graph
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def addAttributes(attr: Attributes): Graph[BidiShape[I, I, O, O], NotUsed]
- Definition Classes
- Graph
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def async(dispatcher: String, inputBufferSize: Int): Graph[BidiShape[I, I, O, O], NotUsed]
- Definition Classes
- Graph
- def async(dispatcher: String): Graph[BidiShape[I, I, O, O], NotUsed]
- Definition Classes
- Graph
- def async: Graph[BidiShape[I, I, O, O], NotUsed]
- Definition Classes
- Graph
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- def createLogic(inheritedAttributes: Attributes): GraphStageLogic
- Definition Classes
- MaxInFlight → GraphStage
- Annotations
- @SuppressWarnings()
- final def createLogicAndMaterializedValue(inheritedAttributes: Attributes): (GraphStageLogic, NotUsed)
- Definition Classes
- GraphStage → GraphStageWithMaterializedValue
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def getAttributes: Attributes
- Definition Classes
- Graph
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- val in1: Inlet[I]
- val in2: Inlet[O]
- def initialAttributes: Attributes
- Attributes
- protected
- Definition Classes
- GraphStageWithMaterializedValue
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def named(name: String): Graph[BidiShape[I, I, O, O], NotUsed]
- Definition Classes
- Graph
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- val out1: Outlet[I]
- val out2: Outlet[O]
- def shape: BidiShape[I, I, O, O]
- Definition Classes
- MaxInFlight → Graph
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def withAttributes(attr: Attributes): Graph[BidiShape[I, I, O, O], NotUsed]
- Definition Classes
- GraphStageWithMaterializedValue → Graph