Package org.apache.pekko.stream.javadsl
Class Balance
java.lang.Object
org.apache.pekko.stream.javadsl.Balance
Fan-out the stream to several streams. Each upstream element is emitted to the first available downstream consumer.
It will not shutdown until the subscriptions for at least
two downstream subscribers have been established.
'''Emits when''' any of the outputs stops backpressuring; emits the element to the first available output
'''Backpressures when''' all of the outputs backpressure
'''Completes when''' upstream completes
'''Cancels when''' If eagerCancel is enabled: when any downstream cancels; otherwise: when all downstreams cancel
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic <T> Graph<UniformFanOutShape<T,T>, NotUsed> create(int outputCount) Create a newBalanceoperator with the specified input type, bothwaitForAllDownstreamsandeagerCancelarefalse.static <T> Graph<UniformFanOutShape<T,T>, NotUsed> create(int outputCount, boolean waitForAllDownstreams) Create a newBalanceoperator with the specified input type,eagerCancelisfalse.static <T> Graph<UniformFanOutShape<T,T>, NotUsed> create(int outputCount, boolean waitForAllDownstreams, boolean eagerCancel) Create a newBalanceoperator with the specified input type.static <T> Graph<UniformFanOutShape<T,T>, NotUsed> Create a newBalanceoperator with the specified input type, bothwaitForAllDownstreamsandeagerCancelarefalse.static <T> Graph<UniformFanOutShape<T,T>, NotUsed> Create a newBalanceoperator with the specified input type,eagerCancelisfalse.static <T> Graph<UniformFanOutShape<T,T>, NotUsed> Create a newBalanceoperator with the specified input type.
-
Constructor Details
-
Balance
public Balance()
-
-
Method Details
-
create
public static <T> Graph<UniformFanOutShape<T,T>, createNotUsed> (int outputCount, boolean waitForAllDownstreams) Create a newBalanceoperator with the specified input type,eagerCancelisfalse.- Parameters:
outputCount- number of output portswaitForAllDownstreams- iftrueit will not start emitting elements to downstream outputs until all of them have requested at least one element
-
create
public static <T> Graph<UniformFanOutShape<T,T>, createNotUsed> (int outputCount, boolean waitForAllDownstreams, boolean eagerCancel) Create a newBalanceoperator with the specified input type.- Parameters:
outputCount- number of output portswaitForAllDownstreams- iftrueit 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.
-
create
Create a newBalanceoperator with the specified input type, bothwaitForAllDownstreamsandeagerCancelarefalse.- Parameters:
outputCount- number of output ports
-
create
Create a newBalanceoperator with the specified input type, bothwaitForAllDownstreamsandeagerCancelarefalse.- Parameters:
clazz- a type hint for this methodoutputCount- number of output ports
-
create
public static <T> Graph<UniformFanOutShape<T,T>, createNotUsed> (Class<T> clazz, int outputCount, boolean waitForAllDownstreams) Create a newBalanceoperator with the specified input type,eagerCancelisfalse.- Parameters:
clazz- a type hint for this methodoutputCount- number of output portswaitForAllDownstreams- iftrueit will not start emitting elements to downstream outputs until all of them have requested at least one element
-
create
public static <T> Graph<UniformFanOutShape<T,T>, createNotUsed> (Class<T> clazz, int outputCount, boolean waitForAllDownstreams, boolean eagerCancel) Create a newBalanceoperator with the specified input type.- Parameters:
clazz- a type hint for this methodoutputCount- number of output portswaitForAllDownstreams- iftrueit 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.
-