Package org.apache.pekko.stream.scaladsl

Class MergePreferred$

java.lang.Object

org.apache.pekko.stream.scaladsl.MergePreferred$

public class MergePreferred$
extends Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
MergePreferred$()

Method Summary

Modifier and Type	Method	Description
<T> MergePreferred<T>	apply(int secondaryPorts, boolean eagerComplete)	Create a new MergePreferred with the specified number of secondary input 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 MergePreferred$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

MergePreferred$

public MergePreferred$()

Method Details

apply

public <T> MergePreferred<T> apply(int secondaryPorts,
 boolean eagerComplete)

Create a new MergePreferred with the specified number of secondary input ports.

Parameters:

secondaryPorts - number of secondary input ports

eagerComplete - if true, the merge will complete as soon as one of its inputs completes.

apply$default$2

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