object UnzipWith extends UnzipWithApply
Transforms each element of input stream into multiple streams using a splitter function.
Emits when all of the outputs stop backpressuring and there is an input element available
Backpressures when any of the outputs backpressure
Completes when upstream completes
Cancels when any downstream cancels
- Source
- Graph.scala
- Alphabetic
- By Inheritance
- UnzipWith
- UnzipWithApply
- 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
- def apply[In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21, A22](unzipper: (In) => (A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21, A22))(implicit creator: UnzipWithCreator22[Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any]): UnzipWith22[In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21, A22]
Create a new
UnzipWith
specialized for 22 outputs.Create a new
UnzipWith
specialized for 22 outputs.- unzipper
unzipping-function from the input value to 22 output values
- Definition Classes
- UnzipWithApply
- def apply[In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21](unzipper: (In) => (A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21))(implicit creator: UnzipWithCreator21[Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any]): UnzipWith21[In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21]
Create a new
UnzipWith
specialized for 21 outputs.Create a new
UnzipWith
specialized for 21 outputs.- unzipper
unzipping-function from the input value to 21 output values
- Definition Classes
- UnzipWithApply
- def apply[In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20](unzipper: (In) => (A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20))(implicit creator: UnzipWithCreator20[Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any]): UnzipWith20[In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20]
Create a new
UnzipWith
specialized for 20 outputs.Create a new
UnzipWith
specialized for 20 outputs.- unzipper
unzipping-function from the input value to 20 output values
- Definition Classes
- UnzipWithApply
- def apply[In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19](unzipper: (In) => (A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19))(implicit creator: UnzipWithCreator19[Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any]): UnzipWith19[In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19]
Create a new
UnzipWith
specialized for 19 outputs.Create a new
UnzipWith
specialized for 19 outputs.- unzipper
unzipping-function from the input value to 19 output values
- Definition Classes
- UnzipWithApply
- def apply[In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18](unzipper: (In) => (A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18))(implicit creator: UnzipWithCreator18[Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any]): UnzipWith18[In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18]
Create a new
UnzipWith
specialized for 18 outputs.Create a new
UnzipWith
specialized for 18 outputs.- unzipper
unzipping-function from the input value to 18 output values
- Definition Classes
- UnzipWithApply
- def apply[In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17](unzipper: (In) => (A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17))(implicit creator: UnzipWithCreator17[Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any]): UnzipWith17[In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17]
Create a new
UnzipWith
specialized for 17 outputs.Create a new
UnzipWith
specialized for 17 outputs.- unzipper
unzipping-function from the input value to 17 output values
- Definition Classes
- UnzipWithApply
- def apply[In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16](unzipper: (In) => (A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16))(implicit creator: UnzipWithCreator16[Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any]): UnzipWith16[In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16]
Create a new
UnzipWith
specialized for 16 outputs.Create a new
UnzipWith
specialized for 16 outputs.- unzipper
unzipping-function from the input value to 16 output values
- Definition Classes
- UnzipWithApply
- def apply[In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15](unzipper: (In) => (A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15))(implicit creator: UnzipWithCreator15[Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any]): UnzipWith15[In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15]
Create a new
UnzipWith
specialized for 15 outputs.Create a new
UnzipWith
specialized for 15 outputs.- unzipper
unzipping-function from the input value to 15 output values
- Definition Classes
- UnzipWithApply
- def apply[In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14](unzipper: (In) => (A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14))(implicit creator: UnzipWithCreator14[Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any]): UnzipWith14[In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14]
Create a new
UnzipWith
specialized for 14 outputs.Create a new
UnzipWith
specialized for 14 outputs.- unzipper
unzipping-function from the input value to 14 output values
- Definition Classes
- UnzipWithApply
- def apply[In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13](unzipper: (In) => (A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13))(implicit creator: UnzipWithCreator13[Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any]): UnzipWith13[In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13]
Create a new
UnzipWith
specialized for 13 outputs.Create a new
UnzipWith
specialized for 13 outputs.- unzipper
unzipping-function from the input value to 13 output values
- Definition Classes
- UnzipWithApply
- def apply[In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12](unzipper: (In) => (A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12))(implicit creator: UnzipWithCreator12[Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any]): UnzipWith12[In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12]
Create a new
UnzipWith
specialized for 12 outputs.Create a new
UnzipWith
specialized for 12 outputs.- unzipper
unzipping-function from the input value to 12 output values
- Definition Classes
- UnzipWithApply
- def apply[In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11](unzipper: (In) => (A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11))(implicit creator: UnzipWithCreator11[Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any]): UnzipWith11[In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11]
Create a new
UnzipWith
specialized for 11 outputs.Create a new
UnzipWith
specialized for 11 outputs.- unzipper
unzipping-function from the input value to 11 output values
- Definition Classes
- UnzipWithApply
- def apply[In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10](unzipper: (In) => (A1, A2, A3, A4, A5, A6, A7, A8, A9, A10))(implicit creator: UnzipWithCreator10[Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any]): UnzipWith10[In, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10]
Create a new
UnzipWith
specialized for 10 outputs.Create a new
UnzipWith
specialized for 10 outputs.- unzipper
unzipping-function from the input value to 10 output values
- Definition Classes
- UnzipWithApply
- def apply[In, A1, A2, A3, A4, A5, A6, A7, A8, A9](unzipper: (In) => (A1, A2, A3, A4, A5, A6, A7, A8, A9))(implicit creator: UnzipWithCreator9[Any, Any, Any, Any, Any, Any, Any, Any, Any, Any]): UnzipWith9[In, A1, A2, A3, A4, A5, A6, A7, A8, A9]
Create a new
UnzipWith
specialized for 9 outputs.Create a new
UnzipWith
specialized for 9 outputs.- unzipper
unzipping-function from the input value to 9 output values
- Definition Classes
- UnzipWithApply
- def apply[In, A1, A2, A3, A4, A5, A6, A7, A8](unzipper: (In) => (A1, A2, A3, A4, A5, A6, A7, A8))(implicit creator: UnzipWithCreator8[Any, Any, Any, Any, Any, Any, Any, Any, Any]): UnzipWith8[In, A1, A2, A3, A4, A5, A6, A7, A8]
Create a new
UnzipWith
specialized for 8 outputs.Create a new
UnzipWith
specialized for 8 outputs.- unzipper
unzipping-function from the input value to 8 output values
- Definition Classes
- UnzipWithApply
- def apply[In, A1, A2, A3, A4, A5, A6, A7](unzipper: (In) => (A1, A2, A3, A4, A5, A6, A7))(implicit creator: UnzipWithCreator7[Any, Any, Any, Any, Any, Any, Any, Any]): UnzipWith7[In, A1, A2, A3, A4, A5, A6, A7]
Create a new
UnzipWith
specialized for 7 outputs.Create a new
UnzipWith
specialized for 7 outputs.- unzipper
unzipping-function from the input value to 7 output values
- Definition Classes
- UnzipWithApply
- def apply[In, A1, A2, A3, A4, A5, A6](unzipper: (In) => (A1, A2, A3, A4, A5, A6))(implicit creator: UnzipWithCreator6[Any, Any, Any, Any, Any, Any, Any]): UnzipWith6[In, A1, A2, A3, A4, A5, A6]
Create a new
UnzipWith
specialized for 6 outputs.Create a new
UnzipWith
specialized for 6 outputs.- unzipper
unzipping-function from the input value to 6 output values
- Definition Classes
- UnzipWithApply
- def apply[In, A1, A2, A3, A4, A5](unzipper: (In) => (A1, A2, A3, A4, A5))(implicit creator: UnzipWithCreator5[Any, Any, Any, Any, Any, Any]): UnzipWith5[In, A1, A2, A3, A4, A5]
Create a new
UnzipWith
specialized for 5 outputs.Create a new
UnzipWith
specialized for 5 outputs.- unzipper
unzipping-function from the input value to 5 output values
- Definition Classes
- UnzipWithApply
- def apply[In, A1, A2, A3, A4](unzipper: (In) => (A1, A2, A3, A4))(implicit creator: UnzipWithCreator4[Any, Any, Any, Any, Any]): UnzipWith4[In, A1, A2, A3, A4]
Create a new
UnzipWith
specialized for 4 outputs.Create a new
UnzipWith
specialized for 4 outputs.- unzipper
unzipping-function from the input value to 4 output values
- Definition Classes
- UnzipWithApply
- def apply[In, A1, A2, A3](unzipper: (In) => (A1, A2, A3))(implicit creator: UnzipWithCreator3[Any, Any, Any, Any]): UnzipWith3[In, A1, A2, A3]
Create a new
UnzipWith
specialized for 3 outputs.Create a new
UnzipWith
specialized for 3 outputs.- unzipper
unzipping-function from the input value to 3 output values
- Definition Classes
- UnzipWithApply
- def apply[In, A1, A2](unzipper: (In) => (A1, A2))(implicit creator: UnzipWithCreator2[Any, Any, Any]): UnzipWith2[In, A1, A2]
Create a new
UnzipWith
specialized for 2 outputs.Create a new
UnzipWith
specialized for 2 outputs.- unzipper
unzipping-function from the input value to 2 output values
- Definition Classes
- UnzipWithApply
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- 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
- @native() @HotSpotIntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- 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
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- 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])