Package org.apache.pekko.stream.scaladsl

Class Balance$

java.lang.Object

org.apache.pekko.stream.scaladsl.Balance$

public class Balance$
extends Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
Balance$()

Method Summary

Modifier and Type	Method	Description
<T> Balance<T>	apply(int outputPorts, boolean waitForAllDownstreams)	Create a new Balance with the specified number of output ports.
<T> boolean	apply$default$2()

Methods inherited from class java.lang.Object

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

Field Details

MODULE$

public static final Balance$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

Balance$

public Balance$()

Method Details

apply

public <T> Balance<T> apply(int outputPorts,
 boolean waitForAllDownstreams)

Create a new Balance with the specified number of output ports. This method sets eagerCancel to false. To specify a different value for the eagerCancel parameter, then instantiate Balance using the constructor.

If eagerCancel is true, balance cancels upstream if any of its downstreams cancel, if false, when all have cancelled.

Parameters:

outputPorts - number of output ports

waitForAllDownstreams - if you use waitForAllDownstreams = true it will not start emitting elements to downstream outputs until all of them have requested at least one element, default value is false

apply$default$2

public <T> boolean apply$default$2()