public final class GroupedWithin<T> extends GraphStage<FlowShape<T,scala.collection.immutable.Seq<T>>>
Constructor and Description |
---|
GroupedWithin(int n,
scala.concurrent.duration.FiniteDuration d) |
Modifier and Type | Method and Description |
---|---|
GraphStageLogic |
createLogic(Attributes inheritedAttributes) |
scala.concurrent.duration.FiniteDuration |
d() |
Inlet<T> |
in() |
Attributes |
initialAttributes() |
int |
n() |
Outlet<scala.collection.immutable.Seq<T>> |
out() |
FlowShape<T,scala.collection.immutable.Seq<T>> |
shape()
The shape of a graph is all that is externally visible: its inlets and outlets.
|
createLogicAndMaterializedValue
module, withAttributes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addAttributes, async, named
public GroupedWithin(int n, scala.concurrent.duration.FiniteDuration d)
public int n()
public scala.concurrent.duration.FiniteDuration d()
public Attributes initialAttributes()
initialAttributes
in class GraphStageWithMaterializedValue<FlowShape<T,scala.collection.immutable.Seq<T>>,NotUsed>
public FlowShape<T,scala.collection.immutable.Seq<T>> shape()
Graph
public GraphStageLogic createLogic(Attributes inheritedAttributes)
createLogic
in class GraphStage<FlowShape<T,scala.collection.immutable.Seq<T>>>