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
UnzipWithspecialized for 22 outputs.Create a new
UnzipWithspecialized 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
UnzipWithspecialized for 21 outputs.Create a new
UnzipWithspecialized 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
UnzipWithspecialized for 20 outputs.Create a new
UnzipWithspecialized 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
UnzipWithspecialized for 19 outputs.Create a new
UnzipWithspecialized 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
UnzipWithspecialized for 18 outputs.Create a new
UnzipWithspecialized 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
UnzipWithspecialized for 17 outputs.Create a new
UnzipWithspecialized 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
UnzipWithspecialized for 16 outputs.Create a new
UnzipWithspecialized 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
UnzipWithspecialized for 15 outputs.Create a new
UnzipWithspecialized 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
UnzipWithspecialized for 14 outputs.Create a new
UnzipWithspecialized 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
UnzipWithspecialized for 13 outputs.Create a new
UnzipWithspecialized 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
UnzipWithspecialized for 12 outputs.Create a new
UnzipWithspecialized 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
UnzipWithspecialized for 11 outputs.Create a new
UnzipWithspecialized 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
UnzipWithspecialized for 10 outputs.Create a new
UnzipWithspecialized 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
UnzipWithspecialized for 9 outputs.Create a new
UnzipWithspecialized 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
UnzipWithspecialized for 8 outputs.Create a new
UnzipWithspecialized 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
UnzipWithspecialized for 7 outputs.Create a new
UnzipWithspecialized 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
UnzipWithspecialized for 6 outputs.Create a new
UnzipWithspecialized 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
UnzipWithspecialized for 5 outputs.Create a new
UnzipWithspecialized 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
UnzipWithspecialized for 4 outputs.Create a new
UnzipWithspecialized 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
UnzipWithspecialized for 3 outputs.Create a new
UnzipWithspecialized 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
UnzipWithspecialized for 2 outputs.Create a new
UnzipWithspecialized 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]) @HotSpotIntrinsicCandidate() @native()
 
 -   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])