object MergePrioritized
- Source
- Graph.scala
- Alphabetic
- By Inheritance
- MergePrioritized
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Value Members
-
def
apply[T](priorities: Seq[Int], eagerComplete: Boolean = false): GraphStage[UniformFanInShape[T, T]]
Create a new
MergePrioritized
with specified number of input ports.Create a new
MergePrioritized
with specified number of input ports.- priorities
priorities of the input ports
- eagerComplete
if true, the merge will complete as soon as one of its inputs completes.