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 newBalancewith the specified number of output ports.<T> booleanapply$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 newBalancewith the specified number of output ports. This method setseagerCanceltofalse. To specify a different value for theeagerCancelparameter, then instantiate Balance using the constructor.If
eagerCancelis 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 = trueit 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()
 
 - 
 
 -