Package akka.stream.scaladsl
Class Concat$
- java.lang.Object
 - 
- akka.stream.scaladsl.Concat$
 
 
- 
public class Concat$ extends java.lang.Object 
- 
- 
Constructor Summary
Constructors Constructor Description Concat$() 
- 
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <T> Graph<UniformFanInShape<T,T>,NotUsed>apply(int inputPorts)Create a newConcat.<T> Graph<UniformFanInShape<T,T>,NotUsed>apply(int inputPorts, boolean detachedInputs)Create a newConcatoperator that will concatenate two or more streams.<T> intapply$default$1() 
 - 
 
- 
- 
Field Detail
- 
MODULE$
public static final Concat$ MODULE$
Static reference to the singleton instance of this Scala object. 
 - 
 
- 
Method Detail
- 
apply
public <T> Graph<UniformFanInShape<T,T>,NotUsed> apply(int inputPorts)
Create a newConcat. 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 newConcatoperator that will concatenate two or more streams.- Parameters:
 inputPorts- The number of fan-in input portsdetachedInputs- 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()
 
 - 
 
 -