MergePrioritized$

java.lang.Object
- akka.stream.scaladsl.MergePrioritized$

public class MergePrioritized$
extends java.lang.Object

Field Summary

Fields
Modifier and Type Field Description

static MergePrioritized$ MODULE$
Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors
Constructor Description

MergePrioritized$()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`<T> GraphStage<UniformFanInShape<T,T>>`	`apply(scala.collection.immutable.Seq<java.lang.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 Detail
  - MODULE$
```
public static final MergePrioritized$ MODULE$
```
    Static reference to the singleton instance of this Scala object.
- Constructor Detail
  - MergePrioritized$
```
public MergePrioritized$()
```
- Method Detail
  - apply
```
public <T> GraphStage<UniformFanInShape<T,T>> apply(scala.collection.immutable.Seq<java.lang.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()
```