Package akka.stream.scaladsl
Class Balance$
- java.lang.Object
-
- akka.stream.scaladsl.Balance$
-
public class Balance$ extends java.lang.Object
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.param: outputPorts number of output ports param: 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
-
-
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)
<T> boolean
apply$default$2()
-