Package akka.stream.scaladsl
Class Balance$
- java.lang.Object
-
- akka.stream.scaladsl.Balance$
-
public class Balance$ extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description Balance$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <T> Balance<T>
apply(int outputPorts, boolean waitForAllDownstreams)
Create a newBalance
with the specified number of output ports.<T> boolean
apply$default$2()
-
-
-
Field Detail
-
MODULE$
public static final Balance$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
apply
public <T> Balance<T> apply(int outputPorts, boolean waitForAllDownstreams)
Create a newBalance
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.- Parameters:
outputPorts
- number of output portswaitForAllDownstreams
- if you usewaitForAllDownstreams = true
it will not start emitting elements to downstream outputs until all of them have requested at least one element, default value isfalse
-
apply$default$2
public <T> boolean apply$default$2()
-
-