o

akka.stream.javadsl

Partition

object Partition

Fan-out the stream to several streams. emitting an incoming upstream element to one downstream consumer according to the partitioner function applied to the element

Emits when all of the outputs stops backpressuring and there is an input element available

Backpressures when one of the outputs backpressure

Completes when upstream completes

Cancels when when one of the downstreams cancel

Source
Graph.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Partition
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. def create[T](clazz: Class[T], outputCount: Int, partitioner: Function[T, Int]): Graph[UniformFanOutShape[T, T], NotUsed]

    Create a new Partition stage with the specified input type.

    Create a new Partition stage with the specified input type.

    outputCount

    number of output ports

    partitioner

    function deciding which output each element will be targeted

  2. def create[T](outputCount: Int, partitioner: Function[T, Int]): Graph[UniformFanOutShape[T, T], NotUsed]

    Create a new Partition stage with the specified input type.

    Create a new Partition stage with the specified input type.

    outputCount

    number of output ports

    partitioner

    function deciding which output each element will be targeted