Package org.apache.pekko.stream.scaladsl

Class Concat$

java.lang.Object

org.apache.pekko.stream.scaladsl.Concat$

public class Concat$
extends Object

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>	apply(int inputPorts)	Create a new Concat.
<T> Graph<UniformFanInShape<T,T>,NotUsed>	apply(int inputPorts, boolean detachedInputs)	Create a new Concat operator that will concatenate two or more streams.
<T> int	apply$default$1()

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

apply

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

Create a new Concat. Note that this for historical reasons creates a "detached" Concat which will eagerly pull each input on materialization and act as a one element buffer for each input.

apply

public <T> Graph<UniformFanInShape<T,T>,NotUsed> apply(int inputPorts,
 boolean detachedInputs)

Create a new Concat operator that will concatenate two or more streams.

Parameters:

inputPorts - The number of fan-in input ports

detachedInputs - If the ports should be detached (eagerly pull both inputs) useful to avoid deadlocks in graphs with loops

Returns:

apply$default$1

public <T> int apply$default$1()