object UnzipWith extends UnzipWithApply
Transforms each element of input stream into multiple streams using a splitter 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
- Graph.scala
- Alphabetic
- By Inheritance
- UnzipWith
- UnzipWithApply
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
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](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[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )