Package akka.stream.scaladsl

Class ZipLatestWith

java.lang.Object

akka.stream.scaladsl.ZipLatestWith

public class ZipLatestWith
extends java.lang.Object

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

Constructor Summary

Constructors

Constructor	Description
ZipLatestWith()

Method Summary

Modifier and Type	Method	Description
static <A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,O> ZipLatestWith10<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,O>	apply(scala.Function10<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,O> zipper)
static <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>	apply(scala.Function11<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,O> zipper)
static <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>	apply(scala.Function12<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,O> zipper)
static <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>	apply(scala.Function13<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,O> zipper)
static <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>	apply(scala.Function14<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,O> zipper)
static <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>	apply(scala.Function15<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,O> zipper)
static <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>	apply(scala.Function16<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,O> zipper)
static <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>	apply(scala.Function17<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,O> zipper)
static <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>	apply(scala.Function18<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,O> zipper)
static <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>	apply(scala.Function19<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,O> zipper)
static <A1,A2,O> ZipLatestWith2<A1,A2,O>	apply(scala.Function2<A1,A2,O> zipper)
static <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>	apply(scala.Function20<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,O> zipper)
static <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>	apply(scala.Function21<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,A21,O> zipper)
static <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>	apply(scala.Function22<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,A21,A22,O> zipper)
static <A1,A2,A3,O> ZipLatestWith3<A1,A2,A3,O>	apply(scala.Function3<A1,A2,A3,O> zipper)
static <A1,A2,A3,A4,O> ZipLatestWith4<A1,A2,A3,A4,O>	apply(scala.Function4<A1,A2,A3,A4,O> zipper)
static <A1,A2,A3,A4,A5,O> ZipLatestWith5<A1,A2,A3,A4,A5,O>	apply(scala.Function5<A1,A2,A3,A4,A5,O> zipper)
static <A1,A2,A3,A4,A5,A6,O> ZipLatestWith6<A1,A2,A3,A4,A5,A6,O>	apply(scala.Function6<A1,A2,A3,A4,A5,A6,O> zipper)
static <A1,A2,A3,A4,A5,A6,A7,O> ZipLatestWith7<A1,A2,A3,A4,A5,A6,A7,O>	apply(scala.Function7<A1,A2,A3,A4,A5,A6,A7,O> zipper)
static <A1,A2,A3,A4,A5,A6,A7,A8,O> ZipLatestWith8<A1,A2,A3,A4,A5,A6,A7,A8,O>	apply(scala.Function8<A1,A2,A3,A4,A5,A6,A7,A8,O> zipper)
static <A1,A2,A3,A4,A5,A6,A7,A8,A9,O> ZipLatestWith9<A1,A2,A3,A4,A5,A6,A7,A8,A9,O>	apply(scala.Function9<A1,A2,A3,A4,A5,A6,A7,A8,A9,O> zipper)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ZipLatestWith

public ZipLatestWith()

Method Detail

apply

public static <A1,A2,O> ZipLatestWith2<A1,A2,O> apply(scala.Function2<A1,A2,O> zipper)

apply

public static <A1,A2,A3,O> ZipLatestWith3<A1,A2,A3,O> apply(scala.Function3<A1,A2,A3,O> zipper)

apply

public static <A1,A2,A3,A4,O> ZipLatestWith4<A1,A2,A3,A4,O> apply(scala.Function4<A1,A2,A3,A4,O> zipper)

apply

public static <A1,A2,A3,A4,A5,O> ZipLatestWith5<A1,A2,A3,A4,A5,O> apply(scala.Function5<A1,A2,A3,A4,A5,O> zipper)

apply

public static <A1,A2,A3,A4,A5,A6,O> ZipLatestWith6<A1,A2,A3,A4,A5,A6,O> apply(scala.Function6<A1,A2,A3,A4,A5,A6,O> zipper)

apply

public static <A1,A2,A3,A4,A5,A6,A7,O> ZipLatestWith7<A1,A2,A3,A4,A5,A6,A7,O> apply(scala.Function7<A1,A2,A3,A4,A5,A6,A7,O> zipper)

apply

public static <A1,A2,A3,A4,A5,A6,A7,A8,O> ZipLatestWith8<A1,A2,A3,A4,A5,A6,A7,A8,O> apply(scala.Function8<A1,A2,A3,A4,A5,A6,A7,A8,O> zipper)

apply

public static <A1,A2,A3,A4,A5,A6,A7,A8,A9,O> ZipLatestWith9<A1,A2,A3,A4,A5,A6,A7,A8,A9,O> apply(scala.Function9<A1,A2,A3,A4,A5,A6,A7,A8,A9,O> zipper)

apply

public static <A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,O> ZipLatestWith10<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,O> apply(scala.Function10<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,O> zipper)

apply

public static <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> apply(scala.Function11<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,O> zipper)

apply

public static <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> apply(scala.Function12<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,O> zipper)

apply

public static <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> apply(scala.Function13<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,O> zipper)

apply

public static <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> apply(scala.Function14<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,O> zipper)

apply

public static <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> apply(scala.Function15<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,O> zipper)

apply

public static <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> apply(scala.Function16<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,O> zipper)

apply

public static <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> apply(scala.Function17<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,O> zipper)

apply

public static <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> apply(scala.Function18<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,O> zipper)

apply

public static <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> apply(scala.Function19<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,O> zipper)

apply

public static <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> apply(scala.Function20<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,O> zipper)

apply

public static <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> apply(scala.Function21<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,A21,O> zipper)

apply

public static <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> apply(scala.Function22<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,A21,A22,O> zipper)