Package org.apache.pekko.stream.javadsl
Class Merge
- java.lang.Object
-
- org.apache.pekko.stream.javadsl.Merge
-
public class Merge extends java.lang.Object
Merge several streams, taking elements as they arrive from input streams (picking randomly when several have elements ready).'''Emits when''' one of the inputs has an element available
'''Backpressures when''' downstream backpressures
'''Completes when''' all upstreams complete (eagerComplete=false) or one upstream completes (eagerComplete=true)
'''Cancels when''' downstream cancels
-
-
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)
Create a newMerge
operator with the specified output type.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 a newMerge
operator with the specified output type.
-
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.
-
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 completes
-
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 completes
-
-