akka.stream.javadsl

Class Concat

java.lang.Object

akka.stream.javadsl.Concat

public class Concat
extends java.lang.Object

Takes two streams and outputs an output stream formed from the two input streams by consuming one stream first emitting all of its elements, then consuming the second stream emitting all of its elements.

'''Emits when''' the current stream has an element available; if the current input completes, it tries the next one

'''Backpressures when''' downstream backpressures

'''Completes when''' all upstreams complete

'''Cancels when''' downstream cancels

Constructor Summary

Constructors

Constructor and Description
Concat()

Method Summary

Modifier and Type	Method and Description
static <T> Graph<UniformFanInShape<T,T>,NotUsed>	create() Create a new anonymous Concat stage with the specified input types.
static <T> Graph<UniformFanInShape<T,T>,NotUsed>	create(java.lang.Class<T> clazz) Create a new anonymous Concat stage with the specified input types.
static <T> Graph<UniformFanInShape<T,T>,NotUsed>	create(int inputCount) Create a new anonymous Concat stage with the specified input types.

Methods inherited from class java.lang.Object

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

Constructor Detail

Concat

public Concat()

Method Detail

create

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

Create a new anonymous Concat stage with the specified input types.

Returns:

(undocumented)

create

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

Create a new anonymous Concat stage with the specified input types.

Parameters:

inputCount - (undocumented)

Returns:

(undocumented)

create

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

Create a new anonymous Concat stage with the specified input types.

Parameters:

clazz - (undocumented)

Returns:

(undocumented)