Package org.apache.pekko.stream.scaladsl

Class Partition$

java.lang.Object

org.apache.pekko.stream.scaladsl.Partition$

public class Partition$
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final Partition$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
Partition$()

Method Summary

Modifier and Type	Method	Description
<T> Partition<T>	apply(int outputPorts, scala.Function1<T,Object> partitioner)	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

Field Details

MODULE$

public static final Partition$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

Partition$

public Partition$()

Method Details

apply

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

Create a new Partition operator with the specified input type. This method sets eagerCancel to false. To specify a different value for the eagerCancel parameter, then instantiate Partition using the constructor.

If eagerCancel is true, partition cancels upstream if any of its downstreams cancel, if false, when all have cancelled.

Parameters:

outputPorts - number of output ports

partitioner - function deciding which output each element will be targeted