Package org.apache.pekko.stream.javadsl

Class Concat

java.lang.Object

org.apache.pekko.stream.javadsl.Concat

public class Concat
extends 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	Description
Concat()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

Concat

public Concat()

Method Details

create

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

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

create

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

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

create

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

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

create

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

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