Package akka.stream.javadsl

Class Partition

java.lang.Object

akka.stream.javadsl.Partition

public class Partition
extends java.lang.Object

Create a new Partition operator with the specified input type, eagerCancel is false.

param: outputCount number of output ports param: partitioner function deciding which output each element will be targeted

Constructor Summary

Constructors

Constructor	Description
Partition()

Method Summary

Modifier and Type	Method	Description
static <T> Graph<UniformFanOutShape<T,T>,NotUsed>	create(int outputCount, Function<T,java.lang.Integer> partitioner)
static <T> Graph<UniformFanOutShape<T,T>,NotUsed>	create(int outputCount, Function<T,java.lang.Integer> partitioner, boolean eagerCancel)	Create a new Partition operator with the specified input type.
static <T> Graph<UniformFanOutShape<T,T>,NotUsed>	create(java.lang.Class<T> clazz, int outputCount, Function<T,java.lang.Integer> partitioner)	Create a new Partition operator with the specified input type, eagerCancel is false.
static <T> Graph<UniformFanOutShape<T,T>,NotUsed>	create(java.lang.Class<T> clazz, int outputCount, Function<T,java.lang.Integer> partitioner, boolean eagerCancel)	Create a new Partition operator with the specified input type.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Partition

public Partition()

Method Detail

create

public static <T> Graph<UniformFanOutShape<T,T>,NotUsed> create(int outputCount,
                                                                            Function<T,java.lang.Integer> partitioner)

create

public static <T> Graph<UniformFanOutShape<T,T>,NotUsed> create(int outputCount,
                                                                            Function<T,java.lang.Integer> partitioner,
                                                                            boolean eagerCancel)

Create a new Partition operator with the specified input type.

Parameters:

outputCount - number of output ports

partitioner - function deciding which output each element will be targeted

eagerCancel - this operator cancels, when any (true) or all (false) of the downstreams cancel

Returns:

(undocumented)

create

public static <T> Graph<UniformFanOutShape<T,T>,NotUsed> create(java.lang.Class<T> clazz,
                                                                            int outputCount,
                                                                            Function<T,java.lang.Integer> partitioner)

Create a new Partition operator with the specified input type, eagerCancel is false.

Parameters:

clazz - a type hint for this method

outputCount - number of output ports

partitioner - function deciding which output each element will be targeted

Returns:

(undocumented)

create

public static <T> Graph<UniformFanOutShape<T,T>,NotUsed> create(java.lang.Class<T> clazz,
                                                                            int outputCount,
                                                                            Function<T,java.lang.Integer> partitioner,
                                                                            boolean eagerCancel)

Create a new Partition operator with the specified input type.

Parameters:

clazz - a type hint for this method

outputCount - number of output ports

partitioner - function deciding which output each element will be targeted

eagerCancel - this operator cancels, when any (true) or all (false) of the downstreams cancel

Returns:

(undocumented)