object Balance
- Source
- Graph.scala
- Alphabetic
- By Inheritance
- Balance
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Value Members
-
def
apply[T](outputPorts: Int, waitForAllDownstreams: Boolean = false): Balance[T]
Create a new
Balance
with the specified number of output ports.Create a new
Balance
with the specified number of output ports. This method setseagerCancel
tofalse
. To specify a different value for theeagerCancel
parameter, then instantiate Balance using the constructor.If
eagerCancel
is true, balance cancels upstream if any of its downstreams cancel, if false, when all have cancelled.- outputPorts
number of output ports
- waitForAllDownstreams
if you use
waitForAllDownstreams = true
it will not start emitting elements to downstream outputs until all of them have requested at least one element, default value isfalse