Package org.apache.pekko.stream.scaladsl

Class MergePrioritized$

java.lang.Object

org.apache.pekko.stream.scaladsl.MergePrioritized$

public class MergePrioritized$
extends Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
MergePrioritized$()

Method Summary

Modifier and Type	Method	Description
<T> GraphStage<UniformFanInShape<T,T>>	apply(scala.collection.immutable.Seq<Object> priorities, boolean eagerComplete)	Create a new MergePrioritized with specified number of 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 MergePrioritized$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

MergePrioritized$

public MergePrioritized$()

Method Details

apply

public <T> GraphStage<UniformFanInShape<T,T>> apply(scala.collection.immutable.Seq<Object> priorities,
 boolean eagerComplete)

Create a new MergePrioritized with specified number of input ports.

Parameters:

priorities - priorities of the 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()