object ZipLatestWith extends ZipLatestWithApply
Combine the elements of multiple streams into a stream of combined elements using a combiner function, picking always the latest of the elements of each source.
No element is emitted until at least one element from each Source becomes available. Whenever a new element appears, the zipping function is invoked with a tuple containing the new element and the other last seen elements.
Emits when all of the inputs have at least an element available, and then each time an element becomes available on either of the inputs
Backpressures when downstream backpressures
Completes when any of the upstreams completes
Cancels when downstream cancels
- Source
- Graph.scala
- Alphabetic
- By Inheritance
- ZipLatestWith
- ZipLatestWithApply
- 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[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): ZipLatestWith22[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
ZipLatestWith
specialized for 22 inputs.Create a new
ZipLatestWith
specialized for 22 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipLatestWithApply
-
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): ZipLatestWith21[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
ZipLatestWith
specialized for 21 inputs.Create a new
ZipLatestWith
specialized for 21 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipLatestWithApply
-
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): ZipLatestWith20[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, O]
Create a new
ZipLatestWith
specialized for 20 inputs.Create a new
ZipLatestWith
specialized for 20 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipLatestWithApply
-
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): ZipLatestWith19[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, O]
Create a new
ZipLatestWith
specialized for 19 inputs.Create a new
ZipLatestWith
specialized for 19 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipLatestWithApply
-
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): ZipLatestWith18[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, O]
Create a new
ZipLatestWith
specialized for 18 inputs.Create a new
ZipLatestWith
specialized for 18 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipLatestWithApply
-
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): ZipLatestWith17[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, O]
Create a new
ZipLatestWith
specialized for 17 inputs.Create a new
ZipLatestWith
specialized for 17 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipLatestWithApply
-
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): ZipLatestWith16[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, O]
Create a new
ZipLatestWith
specialized for 16 inputs.Create a new
ZipLatestWith
specialized for 16 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipLatestWithApply
-
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): ZipLatestWith15[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, O]
Create a new
ZipLatestWith
specialized for 15 inputs.Create a new
ZipLatestWith
specialized for 15 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipLatestWithApply
-
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): ZipLatestWith14[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, O]
Create a new
ZipLatestWith
specialized for 14 inputs.Create a new
ZipLatestWith
specialized for 14 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipLatestWithApply
-
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): ZipLatestWith13[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, O]
Create a new
ZipLatestWith
specialized for 13 inputs.Create a new
ZipLatestWith
specialized for 13 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipLatestWithApply
-
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): ZipLatestWith12[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, O]
Create a new
ZipLatestWith
specialized for 12 inputs.Create a new
ZipLatestWith
specialized for 12 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipLatestWithApply
-
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): ZipLatestWith11[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, O]
Create a new
ZipLatestWith
specialized for 11 inputs.Create a new
ZipLatestWith
specialized for 11 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipLatestWithApply
-
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): ZipLatestWith10[A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, O]
Create a new
ZipLatestWith
specialized for 10 inputs.Create a new
ZipLatestWith
specialized for 10 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipLatestWithApply
-
def
apply[A1, A2, A3, A4, A5, A6, A7, A8, A9, O](zipper: (A1, A2, A3, A4, A5, A6, A7, A8, A9) ⇒ O): ZipLatestWith9[A1, A2, A3, A4, A5, A6, A7, A8, A9, O]
Create a new
ZipLatestWith
specialized for 9 inputs.Create a new
ZipLatestWith
specialized for 9 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipLatestWithApply
-
def
apply[A1, A2, A3, A4, A5, A6, A7, A8, O](zipper: (A1, A2, A3, A4, A5, A6, A7, A8) ⇒ O): ZipLatestWith8[A1, A2, A3, A4, A5, A6, A7, A8, O]
Create a new
ZipLatestWith
specialized for 8 inputs.Create a new
ZipLatestWith
specialized for 8 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipLatestWithApply
-
def
apply[A1, A2, A3, A4, A5, A6, A7, O](zipper: (A1, A2, A3, A4, A5, A6, A7) ⇒ O): ZipLatestWith7[A1, A2, A3, A4, A5, A6, A7, O]
Create a new
ZipLatestWith
specialized for 7 inputs.Create a new
ZipLatestWith
specialized for 7 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipLatestWithApply
-
def
apply[A1, A2, A3, A4, A5, A6, O](zipper: (A1, A2, A3, A4, A5, A6) ⇒ O): ZipLatestWith6[A1, A2, A3, A4, A5, A6, O]
Create a new
ZipLatestWith
specialized for 6 inputs.Create a new
ZipLatestWith
specialized for 6 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipLatestWithApply
-
def
apply[A1, A2, A3, A4, A5, O](zipper: (A1, A2, A3, A4, A5) ⇒ O): ZipLatestWith5[A1, A2, A3, A4, A5, O]
Create a new
ZipLatestWith
specialized for 5 inputs.Create a new
ZipLatestWith
specialized for 5 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipLatestWithApply
-
def
apply[A1, A2, A3, A4, O](zipper: (A1, A2, A3, A4) ⇒ O): ZipLatestWith4[A1, A2, A3, A4, O]
Create a new
ZipLatestWith
specialized for 4 inputs.Create a new
ZipLatestWith
specialized for 4 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipLatestWithApply
-
def
apply[A1, A2, A3, O](zipper: (A1, A2, A3) ⇒ O): ZipLatestWith3[A1, A2, A3, O]
Create a new
ZipLatestWith
specialized for 3 inputs.Create a new
ZipLatestWith
specialized for 3 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipLatestWithApply
-
def
apply[A1, A2, O](zipper: (A1, A2) ⇒ O): ZipLatestWith2[A1, A2, O]
Create a new
ZipLatestWith
specialized for 2 inputs.Create a new
ZipLatestWith
specialized for 2 inputs.- zipper
zipping-function from the input values to the output value
- Definition Classes
- ZipLatestWithApply
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate() @throws( ... )
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
getClass(): Class[_]
- 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( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )