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

Field Summary

Fields

Modifier and Type	Field and Description
static Balance$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
Balance$()

Method Summary

Modifier and Type	Method and Description
<T> Graph<UniformFanOutShape<T,T>,NotUsed>	create(java.lang.Class<T> clazz, int outputCount) Create a new Balance stage with the specified input type.
<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.
<T> Graph<UniformFanOutShape<T,T>,NotUsed>	create(int outputCount) Create a new Balance stage with the specified input type.
<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

Field Detail

MODULE$

public static final Balance$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

Balance$

public Balance$()

Method Detail

create

public <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 <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 <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 <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)