public final class Concat<T> extends GraphStage<UniformFanInShape<T,T>>
A Concat
has one first
port, one second
port and one out
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 and Description |
---|
Concat(int inputPorts) |
Modifier and Type | Method and Description |
---|---|
static Graph<S,M> |
addAttributes(Attributes attr) |
static <T> Graph<UniformFanInShape<T,T>,NotUsed> |
apply(int inputPorts)
Create a new
Concat . |
static Graph<S,M> |
async() |
GraphStageLogic |
createLogic(Attributes inheritedAttributes) |
static scala.Tuple2<GraphStageLogic,NotUsed> |
createLogicAndMaterializedValue(Attributes inheritedAttributes) |
scala.collection.immutable.IndexedSeq<Inlet<T>> |
in() |
Attributes |
initialAttributes() |
int |
inputPorts() |
static StreamLayout.Module |
module() |
static Graph<S,M> |
named(java.lang.String name) |
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() |
static Graph<S,M> |
withAttributes(Attributes attr) |
createLogicAndMaterializedValue
module, withAttributes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addAttributes, async, named
public static <T> Graph<UniformFanInShape<T,T>,NotUsed> apply(int inputPorts)
Concat
.inputPorts
- (undocumented)public static Graph<S,M> named(java.lang.String name)
public static Graph<S,M> async()
public static Graph<S,M> addAttributes(Attributes attr)
public static final StreamLayout.Module module()
public static final Graph<S,M> withAttributes(Attributes attr)
public static final scala.Tuple2<GraphStageLogic,NotUsed> createLogicAndMaterializedValue(Attributes inheritedAttributes)
public int inputPorts()
public Attributes initialAttributes()
initialAttributes
in class GraphStageWithMaterializedValue<UniformFanInShape<T,T>,NotUsed>
public UniformFanInShape<T,T> shape()
Graph
public GraphStageLogic createLogic(Attributes inheritedAttributes)
createLogic
in class GraphStage<UniformFanInShape<T,T>>
public java.lang.String toString()
toString
in class java.lang.Object