Package akka.stream.javadsl

Class Merge$

java.lang.Object

akka.stream.javadsl.Merge$

public class Merge$
extends java.lang.Object

Create a new Merge operator with the specified output type.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
Merge$()

Method Summary

Modifier and Type	Method	Description
<T> Graph<UniformFanInShape<T,T>,NotUsed>	create(int inputPorts)
<T> Graph<UniformFanInShape<T,T>,NotUsed>	create(int inputPorts, boolean eagerComplete)	Create a new Merge operator with the specified output type.
<T> Graph<UniformFanInShape<T,T>,NotUsed>	create(java.lang.Class<T> clazz, int inputPorts)	Create a new Merge operator with the specified output type.
<T> Graph<UniformFanInShape<T,T>,NotUsed>	create(java.lang.Class<T> clazz, int inputPorts, boolean eagerComplete)	Create a new Merge operator with the specified output type.

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final Merge$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

Merge$

public Merge$()

Method Detail

create

public <T> Graph<UniformFanInShape<T,T>,NotUsed> create(int inputPorts)

create

public <T> Graph<UniformFanInShape<T,T>,NotUsed> create(java.lang.Class<T> clazz,
                                                                    int inputPorts)

Create a new Merge operator with the specified output type.

Parameters:

clazz - (undocumented)

inputPorts - (undocumented)

Returns:

(undocumented)

create

public <T> Graph<UniformFanInShape<T,T>,NotUsed> create(int inputPorts,
                                                                    boolean eagerComplete)

Create a new Merge operator with the specified output type.

Parameters:

eagerComplete - set to true in order to make this operator eagerly finish as soon as one of its inputs completes

inputPorts - (undocumented)

Returns:

(undocumented)

create

public <T> Graph<UniformFanInShape<T,T>,NotUsed> create(java.lang.Class<T> clazz,
                                                                    int inputPorts,
                                                                    boolean eagerComplete)

Create a new Merge operator with the specified output type.

Parameters:

eagerComplete - set to true in order to make this operator eagerly finish as soon as one of its inputs completes

clazz - (undocumented)

inputPorts - (undocumented)

Returns:

(undocumented)