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

Adheres to the ActorAttributes.SupervisionStrategy attribute.

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 any (eagerCancel=true) or all (eagerCancel=false) 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. Protected

Value Members

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

    Create a new Partition operator with the specified input type.

    Create a new Partition operator with the specified input type.

    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

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

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

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

    clazz

    a type hint for this method

    outputCount

    number of output ports

    partitioner

    function deciding which output each element will be targeted

  3. def create[T](outputCount: Int, partitioner: Function[T, Integer], eagerCancel: Boolean): Graph[UniformFanOutShape[T, T], NotUsed]

    Create a new Partition operator with the specified input type.

    Create a new Partition operator with the specified input type.

    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

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

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

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

    outputCount

    number of output ports

    partitioner

    function deciding which output each element will be targeted