Package akka.stream.javadsl
Class Balance
- java.lang.Object
-
- akka.stream.javadsl.Balance
-
public class Balance extends java.lang.Object
Create a newBalance
operator with the specified input type,eagerCancel
isfalse
.param: outputCount number of output ports param: waitForAllDownstreams if
true
it will not start emitting elements to downstream outputs until all of them have requested at least one element
-
-
Constructor Summary
Constructors Constructor Description Balance()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <T> Graph<UniformFanOutShape<T,T>,NotUsed>
create(int outputCount)
Create a newBalance
operator with the specified input type, bothwaitForAllDownstreams
andeagerCancel
arefalse
.static <T> Graph<UniformFanOutShape<T,T>,NotUsed>
create(int outputCount, boolean waitForAllDownstreams)
static <T> Graph<UniformFanOutShape<T,T>,NotUsed>
create(int outputCount, boolean waitForAllDownstreams, boolean eagerCancel)
Create a newBalance
operator with the specified input type.static <T> Graph<UniformFanOutShape<T,T>,NotUsed>
create(java.lang.Class<T> clazz, int outputCount)
Create a newBalance
operator with the specified input type, bothwaitForAllDownstreams
andeagerCancel
arefalse
.static <T> Graph<UniformFanOutShape<T,T>,NotUsed>
create(java.lang.Class<T> clazz, int outputCount, boolean waitForAllDownstreams)
Create a newBalance
operator with the specified input type,eagerCancel
isfalse
.static <T> Graph<UniformFanOutShape<T,T>,NotUsed>
create(java.lang.Class<T> clazz, int outputCount, boolean waitForAllDownstreams, boolean eagerCancel)
Create a newBalance
operator with the specified input type.
-
-
-
Method Detail
-
create
public static <T> Graph<UniformFanOutShape<T,T>,NotUsed> create(int outputCount, boolean waitForAllDownstreams)
-
create
public static <T> Graph<UniformFanOutShape<T,T>,NotUsed> create(int outputCount, boolean waitForAllDownstreams, boolean eagerCancel)
Create a newBalance
operator with the specified input type.- Parameters:
outputCount
- number of output portswaitForAllDownstreams
- iftrue
it will not start emitting elements to downstream outputs until all of them have requested at least one elementeagerCancel
- if true, balance cancels upstream if any of its downstreams cancel, if false, when all have cancelled.- Returns:
- (undocumented)
-
create
public static <T> Graph<UniformFanOutShape<T,T>,NotUsed> create(int outputCount)
Create a newBalance
operator with the specified input type, bothwaitForAllDownstreams
andeagerCancel
arefalse
.- Parameters:
outputCount
- number of output ports- Returns:
- (undocumented)
-
create
public static <T> Graph<UniformFanOutShape<T,T>,NotUsed> create(java.lang.Class<T> clazz, int outputCount)
Create a newBalance
operator with the specified input type, bothwaitForAllDownstreams
andeagerCancel
arefalse
.- Parameters:
clazz
- a type hint for this methodoutputCount
- number of output ports- Returns:
- (undocumented)
-
create
public static <T> Graph<UniformFanOutShape<T,T>,NotUsed> create(java.lang.Class<T> clazz, int outputCount, boolean waitForAllDownstreams)
Create a newBalance
operator with the specified input type,eagerCancel
isfalse
.- Parameters:
clazz
- a type hint for this methodoutputCount
- number of output portswaitForAllDownstreams
- iftrue
it will not start emitting elements to downstream outputs until all of them have requested at least one element- Returns:
- (undocumented)
-
create
public static <T> Graph<UniformFanOutShape<T,T>,NotUsed> create(java.lang.Class<T> clazz, int outputCount, boolean waitForAllDownstreams, boolean eagerCancel)
Create a newBalance
operator with the specified input type.- Parameters:
clazz
- a type hint for this methodoutputCount
- number of output portswaitForAllDownstreams
- iftrue
it will not start emitting elements to downstream outputs until all of them have requested at least one elementeagerCancel
- if true, balance cancels upstream if any of its downstreams cancel, if false, when all have cancelled.- Returns:
- (undocumented)
-
-