public class Merge$
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static Merge$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
Merge$() |
Modifier and Type | Method and Description |
---|---|
<T> Merge<T> |
apply(int inputPorts,
boolean eagerComplete)
Create a new
Merge with the specified number of input ports. |
public static final Merge$ MODULE$
public <T> Merge<T> apply(int inputPorts, boolean eagerComplete)
Merge
with the specified number of input ports.
inputPorts
- number of input portseagerComplete
- if true, the merge will complete as soon as one of its inputs completes.