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
- Alphabetic
- By Inheritance
- Partition
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
- 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
- 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
isfalse
.Create a new
Partition
operator with the specified input type,eagerCancel
isfalse
.- clazz
a type hint for this method
- outputCount
number of output ports
- partitioner
function deciding which output each element will be targeted
- 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
- 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
isfalse
.Create a new
Partition
operator with the specified input type,eagerCancel
isfalse
.- outputCount
number of output ports
- partitioner
function deciding which output each element will be targeted
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])