akka.stream.scaladsl

Class MergePreferred$

java.lang.Object

akka.stream.scaladsl.MergePreferred$

public class MergePreferred$
extends java.lang.Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
MergePreferred$()

Method Summary

Modifier and Type	Method and Description
<T> MergePreferred<T>	apply(int secondaryPorts, boolean eagerComplete) Create a new MergePreferred with the specified number of secondary input ports.

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final MergePreferred$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

MergePreferred$

public MergePreferred$()

Method Detail

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.

Returns:

(undocumented)