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

Field Summary

Fields

Modifier and Type	Field	Description
static final Concat$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
Concat$()

Method Summary

Modifier and Type	Method	Description
<T> Graph<UniformFanInShape<T,T>,NotUsed>	create()	Create a new anonymous Concat operator with the specified input types.
<T> Graph<UniformFanInShape<T,T>,NotUsed>	create(int inputCount)	Create a new anonymous Concat operator with the specified input types.
<T> Graph<UniformFanInShape<T,T>,NotUsed>	create(int inputCount, boolean detachedInputs)	Create a new anonymous Concat operator with the specified input types.
<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

Field Details

MODULE$

public static final Concat$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

Concat$

public Concat$()

Method Details

create

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

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

create

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

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

create

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

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

create

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

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