akka.stream.javadsl

Class Balance

java.lang.Object

akka.stream.javadsl.Balance

public class Balance
extends java.lang.Object

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''' all downstreams cancel

Constructor Summary

Constructors

Constructor and Description
Balance()

Method Summary

Modifier and Type	Method and Description
static <T> Graph<UniformFanOutShape<T,T>,NotUsed>	create(java.lang.Class<T> clazz, int outputCount) Create a new Balance stage with the specified input type.
static <T> Graph<UniformFanOutShape<T,T>,NotUsed>	create(java.lang.Class<T> clazz, int outputCount, boolean waitForAllDownstreams) Create a new Balance stage with the specified input type.
static <T> Graph<UniformFanOutShape<T,T>,NotUsed>	create(int outputCount) Create a new Balance stage with the specified input type.
static <T> Graph<UniformFanOutShape<T,T>,NotUsed>	create(int outputCount, boolean waitForAllDownstreams) Create a new Balance stage with the specified input type.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Balance

public Balance()

Method Detail

create

public static <T> Graph<UniformFanOutShape<T,T>,NotUsed> create(int outputCount,
                                                                boolean waitForAllDownstreams)

Create a new Balance stage with the specified input type.

Parameters:

waitForAllDownstreams - if true it will not start emitting elements to downstream outputs until all of them have requested at least one element

outputCount - (undocumented)

Returns:

(undocumented)

create

public static <T> Graph<UniformFanOutShape<T,T>,NotUsed> create(int outputCount)

Create a new Balance stage with the specified input type.

Parameters:

outputCount - (undocumented)

Returns:

(undocumented)

create

public static <T> Graph<UniformFanOutShape<T,T>,NotUsed> create(java.lang.Class<T> clazz,
                                                                int outputCount)

Create a new Balance stage with the specified input type.

Parameters:

clazz - (undocumented)

outputCount - (undocumented)

Returns:

(undocumented)

create

public static <T> Graph<UniformFanOutShape<T,T>,NotUsed> create(java.lang.Class<T> clazz,
                                                                int outputCount,
                                                                boolean waitForAllDownstreams)

Create a new Balance stage with the specified input type.

Parameters:

waitForAllDownstreams - if true it will not start emitting elements to downstream outputs until all of them have requested at least one element

clazz - (undocumented)

outputCount - (undocumented)

Returns:

(undocumented)