object UnzipWith
Split one stream into several streams using a splitting function.
Emits when all of the outputs stops backpressuring and there is an input element available
Backpressures when any of the outputs backpressures
Completes when upstream completes
Cancels when any downstream cancels
- Source
- UnzipWith.scala
- Alphabetic
- By Inheritance
- UnzipWith
- 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[In, A, B](f: Function[In, Pair[A, B]]): Graph[FanOutShape2[In, A, B], NotUsed]
Create a new
UnzipWith
vertex with the specified input type and unzipping-functionf
.Create a new
UnzipWith
vertex with the specified input type and unzipping-functionf
.- f
unzipping-function from the input value to the pair of output values
- def create10[In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10](f: Function[In, Tuple10[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10]]): Graph[FanOutShape10[In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10], NotUsed]
Create a new
UnzipWith
specialized for 10 outputs.Create a new
UnzipWith
specialized for 10 outputs.- f
unzipping-function from the input value to the output values
- def create11[In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11](f: Function[In, Tuple11[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11]]): Graph[FanOutShape11[In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11], NotUsed]
Create a new
UnzipWith
specialized for 11 outputs.Create a new
UnzipWith
specialized for 11 outputs.- f
unzipping-function from the input value to the output values
- def create12[In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12](f: Function[In, Tuple12[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12]]): Graph[FanOutShape12[In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12], NotUsed]
Create a new
UnzipWith
specialized for 12 outputs.Create a new
UnzipWith
specialized for 12 outputs.- f
unzipping-function from the input value to the output values
- def create13[In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13](f: Function[In, Tuple13[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13]]): Graph[FanOutShape13[In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13], NotUsed]
Create a new
UnzipWith
specialized for 13 outputs.Create a new
UnzipWith
specialized for 13 outputs.- f
unzipping-function from the input value to the output values
- def create14[In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14](f: Function[In, Tuple14[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14]]): Graph[FanOutShape14[In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14], NotUsed]
Create a new
UnzipWith
specialized for 14 outputs.Create a new
UnzipWith
specialized for 14 outputs.- f
unzipping-function from the input value to the output values
- def create15[In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15](f: Function[In, Tuple15[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15]]): Graph[FanOutShape15[In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15], NotUsed]
Create a new
UnzipWith
specialized for 15 outputs.Create a new
UnzipWith
specialized for 15 outputs.- f
unzipping-function from the input value to the output values
- def create16[In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16](f: Function[In, Tuple16[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16]]): Graph[FanOutShape16[In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16], NotUsed]
Create a new
UnzipWith
specialized for 16 outputs.Create a new
UnzipWith
specialized for 16 outputs.- f
unzipping-function from the input value to the output values
- def create17[In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17](f: Function[In, Tuple17[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17]]): Graph[FanOutShape17[In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17], NotUsed]
Create a new
UnzipWith
specialized for 17 outputs.Create a new
UnzipWith
specialized for 17 outputs.- f
unzipping-function from the input value to the output values
- def create18[In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18](f: Function[In, Tuple18[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18]]): Graph[FanOutShape18[In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18], NotUsed]
Create a new
UnzipWith
specialized for 18 outputs.Create a new
UnzipWith
specialized for 18 outputs.- f
unzipping-function from the input value to the output values
- def create19[In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19](f: Function[In, Tuple19[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19]]): Graph[FanOutShape19[In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19], NotUsed]
Create a new
UnzipWith
specialized for 19 outputs.Create a new
UnzipWith
specialized for 19 outputs.- f
unzipping-function from the input value to the output values
- def create20[In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20](f: Function[In, Tuple20[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20]]): Graph[FanOutShape20[In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20], NotUsed]
Create a new
UnzipWith
specialized for 20 outputs.Create a new
UnzipWith
specialized for 20 outputs.- f
unzipping-function from the input value to the output values
- def create21[In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21](f: Function[In, Tuple21[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21]]): Graph[FanOutShape21[In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21], NotUsed]
Create a new
UnzipWith
specialized for 21 outputs.Create a new
UnzipWith
specialized for 21 outputs.- f
unzipping-function from the input value to the output values
- def create22[In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, T22](f: Function[In, Tuple22[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, T22]]): Graph[FanOutShape22[In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, T22], NotUsed]
Create a new
UnzipWith
specialized for 22 outputs.Create a new
UnzipWith
specialized for 22 outputs.- f
unzipping-function from the input value to the output values
- def create3[In, T1, T2, T3](f: Function[In, Tuple3[T1, T2, T3]]): Graph[FanOutShape3[In, T1, T2, T3], NotUsed]
Create a new
UnzipWith
specialized for 3 outputs.Create a new
UnzipWith
specialized for 3 outputs.- f
unzipping-function from the input value to the output values
- def create4[In, T1, T2, T3, T4](f: Function[In, Tuple4[T1, T2, T3, T4]]): Graph[FanOutShape4[In, T1, T2, T3, T4], NotUsed]
Create a new
UnzipWith
specialized for 4 outputs.Create a new
UnzipWith
specialized for 4 outputs.- f
unzipping-function from the input value to the output values
- def create5[In, T1, T2, T3, T4, T5](f: Function[In, Tuple5[T1, T2, T3, T4, T5]]): Graph[FanOutShape5[In, T1, T2, T3, T4, T5], NotUsed]
Create a new
UnzipWith
specialized for 5 outputs.Create a new
UnzipWith
specialized for 5 outputs.- f
unzipping-function from the input value to the output values
- def create6[In, T1, T2, T3, T4, T5, T6](f: Function[In, Tuple6[T1, T2, T3, T4, T5, T6]]): Graph[FanOutShape6[In, T1, T2, T3, T4, T5, T6], NotUsed]
Create a new
UnzipWith
specialized for 6 outputs.Create a new
UnzipWith
specialized for 6 outputs.- f
unzipping-function from the input value to the output values
- def create7[In, T1, T2, T3, T4, T5, T6, T7](f: Function[In, Tuple7[T1, T2, T3, T4, T5, T6, T7]]): Graph[FanOutShape7[In, T1, T2, T3, T4, T5, T6, T7], NotUsed]
Create a new
UnzipWith
specialized for 7 outputs.Create a new
UnzipWith
specialized for 7 outputs.- f
unzipping-function from the input value to the output values
- def create8[In, T1, T2, T3, T4, T5, T6, T7, T8](f: Function[In, Tuple8[T1, T2, T3, T4, T5, T6, T7, T8]]): Graph[FanOutShape8[In, T1, T2, T3, T4, T5, T6, T7, T8], NotUsed]
Create a new
UnzipWith
specialized for 8 outputs.Create a new
UnzipWith
specialized for 8 outputs.- f
unzipping-function from the input value to the output values
- def create9[In, T1, T2, T3, T4, T5, T6, T7, T8, T9](f: Function[In, Tuple9[T1, T2, T3, T4, T5, T6, T7, T8, T9]]): Graph[FanOutShape9[In, T1, T2, T3, T4, T5, T6, T7, T8, T9], NotUsed]
Create a new
UnzipWith
specialized for 9 outputs.Create a new
UnzipWith
specialized for 9 outputs.- f
unzipping-function from the input value to the output values
- 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])