object ZipWith extends ZipWithApply
Combine the elements of multiple streams into a stream of combined elements using a combiner function.
Emits when all of the inputs has an element available
Backpressures when downstream backpressures
Completes when any upstream completes
Cancels when downstream cancels
Adheres to the ActorAttributes.SupervisionStrategy attribute.
If the combiner function throws and the supervision decision is pekko.stream.Supervision.Stop the stream fails. If the supervision decision is pekko.stream.Supervision.Resume or pekko.stream.Supervision.Restart the zipped element is dropped and the stream continues.
- Source
- Graph.scala
- Alphabetic
- By Inheritance
- ZipWith
- ZipWithApply
- 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[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21, A22, O](zipper: (A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21, A22) => O): ZipWith22[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21, A22, O]
Create a new
ZipWithspecialized for 22 inputs.Create a new
ZipWithspecialized for 22 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipWithApply
- def apply[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21, O](zipper: (A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21) => O): ZipWith21[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21, O]
Create a new
ZipWithspecialized for 21 inputs.Create a new
ZipWithspecialized for 21 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipWithApply
- def apply[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, O](zipper: (A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20) => O): ZipWith20[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, O]
Create a new
ZipWithspecialized for 20 inputs.Create a new
ZipWithspecialized for 20 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipWithApply
- def apply[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, O](zipper: (A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19) => O): ZipWith19[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, O]
Create a new
ZipWithspecialized for 19 inputs.Create a new
ZipWithspecialized for 19 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipWithApply
- def apply[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, O](zipper: (A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18) => O): ZipWith18[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, O]
Create a new
ZipWithspecialized for 18 inputs.Create a new
ZipWithspecialized for 18 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipWithApply
- def apply[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, O](zipper: (A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17) => O): ZipWith17[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, O]
Create a new
ZipWithspecialized for 17 inputs.Create a new
ZipWithspecialized for 17 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipWithApply
- def apply[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, O](zipper: (A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16) => O): ZipWith16[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, O]
Create a new
ZipWithspecialized for 16 inputs.Create a new
ZipWithspecialized for 16 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipWithApply
- def apply[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, O](zipper: (A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15) => O): ZipWith15[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, O]
Create a new
ZipWithspecialized for 15 inputs.Create a new
ZipWithspecialized for 15 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipWithApply
- def apply[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, O](zipper: (A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14) => O): ZipWith14[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, O]
Create a new
ZipWithspecialized for 14 inputs.Create a new
ZipWithspecialized for 14 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipWithApply
- def apply[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, O](zipper: (A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13) => O): ZipWith13[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, O]
Create a new
ZipWithspecialized for 13 inputs.Create a new
ZipWithspecialized for 13 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipWithApply
- def apply[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, O](zipper: (A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12) => O): ZipWith12[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, O]
Create a new
ZipWithspecialized for 12 inputs.Create a new
ZipWithspecialized for 12 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipWithApply
- def apply[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, O](zipper: (A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11) => O): ZipWith11[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, O]
Create a new
ZipWithspecialized for 11 inputs.Create a new
ZipWithspecialized for 11 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipWithApply
- def apply[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, O](zipper: (A1, A2, A3, A4, A5, A6, A7, A8, A9, A10) => O): ZipWith10[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, O]
Create a new
ZipWithspecialized for 10 inputs.Create a new
ZipWithspecialized for 10 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipWithApply
- def apply[A1, A2, A3, A4, A5, A6, A7, A8, A9, O](zipper: (A1, A2, A3, A4, A5, A6, A7, A8, A9) => O): ZipWith9[A1, A2, A3, A4, A5, A6, A7, A8, A9, O]
Create a new
ZipWithspecialized for 9 inputs.Create a new
ZipWithspecialized for 9 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipWithApply
- def apply[A1, A2, A3, A4, A5, A6, A7, A8, O](zipper: (A1, A2, A3, A4, A5, A6, A7, A8) => O): ZipWith8[A1, A2, A3, A4, A5, A6, A7, A8, O]
Create a new
ZipWithspecialized for 8 inputs.Create a new
ZipWithspecialized for 8 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipWithApply
- def apply[A1, A2, A3, A4, A5, A6, A7, O](zipper: (A1, A2, A3, A4, A5, A6, A7) => O): ZipWith7[A1, A2, A3, A4, A5, A6, A7, O]
Create a new
ZipWithspecialized for 7 inputs.Create a new
ZipWithspecialized for 7 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipWithApply
- def apply[A1, A2, A3, A4, A5, A6, O](zipper: (A1, A2, A3, A4, A5, A6) => O): ZipWith6[A1, A2, A3, A4, A5, A6, O]
Create a new
ZipWithspecialized for 6 inputs.Create a new
ZipWithspecialized for 6 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipWithApply
- def apply[A1, A2, A3, A4, A5, O](zipper: (A1, A2, A3, A4, A5) => O): ZipWith5[A1, A2, A3, A4, A5, O]
Create a new
ZipWithspecialized for 5 inputs.Create a new
ZipWithspecialized for 5 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipWithApply
- def apply[A1, A2, A3, A4, O](zipper: (A1, A2, A3, A4) => O): ZipWith4[A1, A2, A3, A4, O]
Create a new
ZipWithspecialized for 4 inputs.Create a new
ZipWithspecialized for 4 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipWithApply
- def apply[A1, A2, A3, O](zipper: (A1, A2, A3) => O): ZipWith3[A1, A2, A3, O]
Create a new
ZipWithspecialized for 3 inputs.Create a new
ZipWithspecialized for 3 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipWithApply
- def apply[A1, A2, O](zipper: (A1, A2) => O): ZipWith2[A1, A2, O]
Create a new
ZipWithspecialized for 2 inputs.Create a new
ZipWithspecialized for 2 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipWithApply
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @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
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @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
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @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])