public final class SeqStage<T> extends GraphStageWithMaterializedValue<SinkShape<T>,scala.concurrent.Future<scala.collection.immutable.Seq<T>>>
Constructor and Description |
---|
SeqStage() |
Modifier and Type | Method and Description |
---|---|
scala.Tuple2<GraphStageLogic,scala.concurrent.Future<scala.collection.immutable.Seq<T>>> |
createLogicAndMaterializedValue(Attributes inheritedAttributes) |
Inlet<T> |
in() |
protected Attributes |
initialAttributes() |
SinkShape<T> |
shape()
The shape of a graph is all that is externally visible: its inlets and outlets.
|
java.lang.String |
toString() |
module, withAttributes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addAttributes, async, named
public java.lang.String toString()
toString
in class java.lang.Object
public SinkShape<T> shape()
Graph
protected Attributes initialAttributes()
initialAttributes
in class GraphStageWithMaterializedValue<SinkShape<T>,scala.concurrent.Future<scala.collection.immutable.Seq<T>>>
public scala.Tuple2<GraphStageLogic,scala.concurrent.Future<scala.collection.immutable.Seq<T>>> createLogicAndMaterializedValue(Attributes inheritedAttributes)
createLogicAndMaterializedValue
in class GraphStageWithMaterializedValue<SinkShape<T>,scala.concurrent.Future<scala.collection.immutable.Seq<T>>>