GroupedWithin

java.lang.Object
- akka.stream.stage.GraphStageWithMaterializedValue<S,NotUsed>
- - akka.stream.stage.GraphStage<FlowShape<T,scala.collection.immutable.Seq<T>>>
  - - akka.stream.impl.fusing.GroupedWithin<T>

All Implemented Interfaces:: Graph<FlowShape<T,scala.collection.immutable.Seq<T>>,NotUsed>

public final class GroupedWithin<T>
extends GraphStage<FlowShape<T,scala.collection.immutable.Seq<T>>>

Constructors
Constructor and Description
`GroupedWithin(int n, scala.concurrent.duration.FiniteDuration d)`

All Methods Instance Methods Concrete Methods
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.

Methods inherited from class akka.stream.stage.GraphStage
createLogicAndMaterializedValue

Methods inherited from class akka.stream.stage.GraphStageWithMaterializedValue
module, withAttributes

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface akka.stream.Graph
addAttributes, async, named

Class GroupedWithin<T>