akka.stream.javadsl

Class Merge

java.lang.Object

akka.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 and Description
Merge()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

Merge

public Merge()

Method Detail

create

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

Create a new Merge stage with the specified output type.

Parameters:

inputPorts - (undocumented)

Returns:

(undocumented)

create

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

Create a new Merge stage 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 new Merge stage with the specified output type.

Parameters:

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

inputPorts - (undocumented)

Returns:

(undocumented)

create

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

Create a new Merge stage with the specified output type.

Parameters:

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

clazz - (undocumented)

inputPorts - (undocumented)

Returns:

(undocumented)