Package akka.stream.javadsl
Class Merge
- java.lang.Object
-
- akka.stream.javadsl.Merge
-
public class Merge extends java.lang.Object
Create a newMerge
operator with the specified output type.
-
-
Constructor Summary
Constructors Constructor Description Merge()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <T> Graph<UniformFanInShape<T,T>,NotUsed>
create(int inputPorts)
static <T> Graph<UniformFanInShape<T,T>,NotUsed>
create(int inputPorts, boolean eagerComplete)
Create a newMerge
operator with the specified output type.static <T> Graph<UniformFanInShape<T,T>,NotUsed>
create(java.lang.Class<T> clazz, int inputPorts)
Create a newMerge
operator with the specified output type.static <T> Graph<UniformFanInShape<T,T>,NotUsed>
create(java.lang.Class<T> clazz, int inputPorts, boolean eagerComplete)
Create a newMerge
operator with the specified output type.
-
-
-
Method Detail
-
create
public static <T> Graph<UniformFanInShape<T,T>,NotUsed> create(int inputPorts)
-
create
public static <T> Graph<UniformFanInShape<T,T>,NotUsed> create(java.lang.Class<T> clazz, int inputPorts)
Create a newMerge
operator with the specified output type.- Parameters:
clazz
- (undocumented)inputPorts
- (undocumented)- Returns:
- (undocumented)
-
create
public static <T> Graph<UniformFanInShape<T,T>,NotUsed> create(int inputPorts, boolean eagerComplete)
Create a newMerge
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 completesinputPorts
- (undocumented)- Returns:
- (undocumented)
-
create
public static <T> Graph<UniformFanInShape<T,T>,NotUsed> create(java.lang.Class<T> clazz, int inputPorts, boolean eagerComplete)
Create a newMerge
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 completesclazz
- (undocumented)inputPorts
- (undocumented)- Returns:
- (undocumented)
-
-