Package akka.stream.scaladsl
Class Concat<T>
- java.lang.Object
-
- akka.stream.stage.GraphStageWithMaterializedValue<S,NotUsed>
-
- akka.stream.stage.GraphStage<UniformFanInShape<T,T>>
-
- akka.stream.scaladsl.Concat<T>
-
- All Implemented Interfaces:
Graph<UniformFanInShape<T,T>,NotUsed>
public final class Concat<T> extends GraphStage<UniformFanInShape<T,T>>
Takes multiple streams and outputs one stream formed from the input streams by first emitting all of the elements from the first stream and then emitting all of the elements from the second stream, etc.A
Concat
has onefirst
port, onesecond
port and oneout
port.'''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(int inputPorts)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static <T> Graph<UniformFanInShape<T,T>,NotUsed>
apply(int inputPorts)
static <T> int
apply$default$1()
GraphStageLogic
createLogic(Attributes inheritedAttributes)
scala.collection.immutable.IndexedSeq<Inlet<T>>
in()
Attributes
initialAttributes()
int
inputPorts()
Outlet<T>
out()
UniformFanInShape<T,T>
shape()
The shape of a graph is all that is externally visible: its inlets and outlets.java.lang.String
toString()
-
Methods inherited from class akka.stream.stage.GraphStage
createLogicAndMaterializedValue
-
Methods inherited from class akka.stream.stage.GraphStageWithMaterializedValue
createLogicAndMaterializedValue, traversalBuilder, withAttributes
-
-
-
-
Method Detail
-
apply
public static <T> Graph<UniformFanInShape<T,T>,NotUsed> apply(int inputPorts)
-
apply$default$1
public static <T> int apply$default$1()
-
inputPorts
public int inputPorts()
-
initialAttributes
public Attributes initialAttributes()
- Overrides:
initialAttributes
in classGraphStageWithMaterializedValue<UniformFanInShape<T,T>,NotUsed>
-
shape
public UniformFanInShape<T,T> shape()
Description copied from interface:Graph
The shape of a graph is all that is externally visible: its inlets and outlets.- Returns:
- (undocumented)
-
createLogic
public GraphStageLogic createLogic(Attributes inheritedAttributes)
- Specified by:
createLogic
in classGraphStage<UniformFanInShape<T,T>>
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-