object ZipWith
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
- Source
- ZipWith.scala
- Alphabetic
- By Inheritance
- ZipWith
- 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]) @native() @HotSpotIntrinsicCandidate()
- def create[A, B, Out](f: Function2[A, B, Out]): Graph[FanInShape2[A, B, Out], NotUsed]
Create a new
ZipWith
vertex with the specified input types and zipping-functionf
.Create a new
ZipWith
vertex with the specified input types and zipping-functionf
.- f
zipping-function from the input values to the output value
- def create10[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, Out](f: Function10[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, Out]): Graph[FanInShape10[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, Out], NotUsed]
Create a new
ZipWith
specialized for 10 inputs.Create a new
ZipWith
specialized for 10 inputs.- f
zipping-function from the input values to the output value
- def create11[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, Out](f: Function11[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, Out]): Graph[FanInShape11[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, Out], NotUsed]
Create a new
ZipWith
specialized for 11 inputs.Create a new
ZipWith
specialized for 11 inputs.- f
zipping-function from the input values to the output value
- def create12[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, Out](f: Function12[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, Out]): Graph[FanInShape12[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, Out], NotUsed]
Create a new
ZipWith
specialized for 12 inputs.Create a new
ZipWith
specialized for 12 inputs.- f
zipping-function from the input values to the output value
- def create13[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, Out](f: Function13[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, Out]): Graph[FanInShape13[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, Out], NotUsed]
Create a new
ZipWith
specialized for 13 inputs.Create a new
ZipWith
specialized for 13 inputs.- f
zipping-function from the input values to the output value
- def create14[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, Out](f: Function14[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, Out]): Graph[FanInShape14[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, Out], NotUsed]
Create a new
ZipWith
specialized for 14 inputs.Create a new
ZipWith
specialized for 14 inputs.- f
zipping-function from the input values to the output value
- def create15[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, Out](f: Function15[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, Out]): Graph[FanInShape15[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, Out], NotUsed]
Create a new
ZipWith
specialized for 15 inputs.Create a new
ZipWith
specialized for 15 inputs.- f
zipping-function from the input values to the output value
- def create16[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, Out](f: Function16[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, Out]): Graph[FanInShape16[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, Out], NotUsed]
Create a new
ZipWith
specialized for 16 inputs.Create a new
ZipWith
specialized for 16 inputs.- f
zipping-function from the input values to the output value
- def create17[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, Out](f: Function17[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, Out]): Graph[FanInShape17[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, Out], NotUsed]
Create a new
ZipWith
specialized for 17 inputs.Create a new
ZipWith
specialized for 17 inputs.- f
zipping-function from the input values to the output value
- def create18[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, Out](f: Function18[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, Out]): Graph[FanInShape18[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, Out], NotUsed]
Create a new
ZipWith
specialized for 18 inputs.Create a new
ZipWith
specialized for 18 inputs.- f
zipping-function from the input values to the output value
- def create19[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, Out](f: Function19[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, Out]): Graph[FanInShape19[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, Out], NotUsed]
Create a new
ZipWith
specialized for 19 inputs.Create a new
ZipWith
specialized for 19 inputs.- f
zipping-function from the input values to the output value
- def create20[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, Out](f: Function20[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, Out]): Graph[FanInShape20[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, Out], NotUsed]
Create a new
ZipWith
specialized for 20 inputs.Create a new
ZipWith
specialized for 20 inputs.- f
zipping-function from the input values to the output value
- def create21[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, Out](f: Function21[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, Out]): Graph[FanInShape21[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, Out], NotUsed]
Create a new
ZipWith
specialized for 21 inputs.Create a new
ZipWith
specialized for 21 inputs.- f
zipping-function from the input values to the output value
- def create22[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, T22, Out](f: Function22[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, T22, Out]): Graph[FanInShape22[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, T22, Out], NotUsed]
Create a new
ZipWith
specialized for 22 inputs.Create a new
ZipWith
specialized for 22 inputs.- f
zipping-function from the input values to the output value
- def create3[T1, T2, T3, Out](f: Function3[T1, T2, T3, Out]): Graph[FanInShape3[T1, T2, T3, Out], NotUsed]
Create a new
ZipWith
specialized for 3 inputs.Create a new
ZipWith
specialized for 3 inputs.- f
zipping-function from the input values to the output value
- def create4[T1, T2, T3, T4, Out](f: Function4[T1, T2, T3, T4, Out]): Graph[FanInShape4[T1, T2, T3, T4, Out], NotUsed]
Create a new
ZipWith
specialized for 4 inputs.Create a new
ZipWith
specialized for 4 inputs.- f
zipping-function from the input values to the output value
- def create5[T1, T2, T3, T4, T5, Out](f: Function5[T1, T2, T3, T4, T5, Out]): Graph[FanInShape5[T1, T2, T3, T4, T5, Out], NotUsed]
Create a new
ZipWith
specialized for 5 inputs.Create a new
ZipWith
specialized for 5 inputs.- f
zipping-function from the input values to the output value
- def create6[T1, T2, T3, T4, T5, T6, Out](f: Function6[T1, T2, T3, T4, T5, T6, Out]): Graph[FanInShape6[T1, T2, T3, T4, T5, T6, Out], NotUsed]
Create a new
ZipWith
specialized for 6 inputs.Create a new
ZipWith
specialized for 6 inputs.- f
zipping-function from the input values to the output value
- def create7[T1, T2, T3, T4, T5, T6, T7, Out](f: Function7[T1, T2, T3, T4, T5, T6, T7, Out]): Graph[FanInShape7[T1, T2, T3, T4, T5, T6, T7, Out], NotUsed]
Create a new
ZipWith
specialized for 7 inputs.Create a new
ZipWith
specialized for 7 inputs.- f
zipping-function from the input values to the output value
- def create8[T1, T2, T3, T4, T5, T6, T7, T8, Out](f: Function8[T1, T2, T3, T4, T5, T6, T7, T8, Out]): Graph[FanInShape8[T1, T2, T3, T4, T5, T6, T7, T8, Out], NotUsed]
Create a new
ZipWith
specialized for 8 inputs.Create a new
ZipWith
specialized for 8 inputs.- f
zipping-function from the input values to the output value
- def create9[T1, T2, T3, T4, T5, T6, T7, T8, T9, Out](f: Function9[T1, T2, T3, T4, T5, T6, T7, T8, T9, Out]): Graph[FanInShape9[T1, T2, T3, T4, T5, T6, T7, T8, T9, Out], NotUsed]
Create a new
ZipWith
specialized for 9 inputs.Create a new
ZipWith
specialized for 9 inputs.- f
zipping-function from the input values to the output value
- 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])