GroupBy

java.lang.Object
- akka.stream.stage.GraphStageWithMaterializedValue<S,NotUsed>
- - akka.stream.stage.GraphStage<FlowShape<T,Source<T,NotUsed>>>
  - - akka.stream.impl.fusing.GroupBy<T,K>

All Implemented Interfaces:: Graph<FlowShape<T,Source<T,NotUsed>>,NotUsed>

public final class GroupBy<T,K>
extends GraphStage<FlowShape<T,Source<T,NotUsed>>>

INTERNAL API

Constructor Summary

Constructors
Constructor Description

GroupBy(int maxSubstreams, scala.Function1<T,K> keyFor, boolean allowClosedSubstreamRecreation)

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`static <T,K> boolean`	`$lessinit$greater$default$3()`
`boolean`	`allowClosedSubstreamRecreation()`
`GraphStageLogic`	`createLogic(Attributes inheritedAttributes)`
`Inlet<T>`	`in()`
`Attributes`	`initialAttributes()`
`scala.Function1<T,K>`	`keyFor()`
`int`	`maxSubstreams()`
`Outlet<Source<T,NotUsed>>`	`out()`
`FlowShape<T,Source<T,NotUsed>>`	`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

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

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

Constructor Detail

GroupBy

public GroupBy(int maxSubstreams,
               scala.Function1<T,K> keyFor,
               boolean allowClosedSubstreamRecreation)

Method Detail
- $lessinit$greater$default$3
```
public static <T,K> boolean $lessinit$greater$default$3()
```
- maxSubstreams
```
public int maxSubstreams()
```
- keyFor
```
public scala.Function1<T,K> keyFor()
```
- allowClosedSubstreamRecreation
```
public boolean allowClosedSubstreamRecreation()
```
- in
```
public Inlet<T> in()
```
- out
```
public Outlet<Source<T,NotUsed>> out()
```
- shape
```
public FlowShape<T,Source<T,NotUsed>> shape()
```
  Description copied from interface: Graph
  
  The shape of a graph is all that is externally visible: its inlets and outlets.
  
  Returns:
  
  (undocumented)
- initialAttributes
```
public Attributes initialAttributes()
```
  Overrides:
  
  initialAttributes in class GraphStageWithMaterializedValue<FlowShape<T,Source<T,NotUsed>>,NotUsed>
- createLogic
```
public GraphStageLogic createLogic(Attributes inheritedAttributes)
```
  Specified by:
  
  createLogic in class GraphStage<FlowShape<T,Source<T,NotUsed>>>
- toString
```
public java.lang.String toString()
```
  Overrides:
  
  toString in class java.lang.Object