Package akka.stream.scaladsl

Class Partition<T>

java.lang.Object

akka.stream.stage.GraphStageWithMaterializedValue<S,NotUsed>

akka.stream.stage.GraphStage<UniformFanOutShape<T,T>>

akka.stream.scaladsl.Partition<T>

All Implemented Interfaces:

Graph<UniformFanOutShape<T,T>,NotUsed>

public final class Partition<T>
extends GraphStage<UniformFanOutShape<T,T>>

Sets eagerCancel to false.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Partition.PartitionOutOfBoundsException
static class	Partition.PartitionOutOfBoundsException$

Constructor Summary

Constructors

Constructor	Description
Partition(int outputPorts, scala.Function1<T,java.lang.Object> partitioner)	Deprecated. Use the constructor which also specifies the `eagerCancel` parameter.
Partition(int outputPorts, scala.Function1<T,java.lang.Object> partitioner, boolean eagerCancel)

Method Summary

Modifier and Type	Method	Description
static <T> Partition<T>	apply(int outputPorts, scala.Function1<T,java.lang.Object> partitioner)
GraphStageLogic	createLogic(Attributes inheritedAttributes)
boolean	eagerCancel()
Inlet<T>	in()
scala.collection.Seq<Outlet<T>>	out()
int	outputPorts()
scala.Function1<T,java.lang.Object>	partitioner()
UniformFanOutShape<T,T>	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, initialAttributes, 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

Partition

public Partition(int outputPorts,
                 scala.Function1<T,java.lang.Object> partitioner,
                 boolean eagerCancel)

Partition

public Partition(int outputPorts,
                 scala.Function1<T,java.lang.Object> partitioner)

Deprecated.

Use the constructor which also specifies the `eagerCancel` parameter. Since 2.5.10.

Method Detail

apply

public static <T> Partition<T> apply(int outputPorts,
                                     scala.Function1<T,java.lang.Object> partitioner)

outputPorts

public int outputPorts()

partitioner

public scala.Function1<T,java.lang.Object> partitioner()

eagerCancel

public boolean eagerCancel()

in

public Inlet<T> in()

out

public scala.collection.Seq<Outlet<T>> out()

shape

public UniformFanOutShape<T,T> shape()

Description copied from interface: Graph

The shape of a graph is all that is externally visible: its inlets and outlets.

Returns:

(undocumented)

createLogic

public GraphStageLogic createLogic(Attributes inheritedAttributes)

Specified by:

createLogic in class GraphStage<UniformFanOutShape<T,T>>

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object