Package akka.stream.javadsl
Class ZipLatestWith$
- java.lang.Object
-
- akka.stream.javadsl.ZipLatestWith$
-
public class ZipLatestWith$ extends java.lang.ObjectCombine 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
-
-
Field Summary
Fields Modifier and Type Field Description static ZipLatestWith$MODULE$Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description ZipLatestWith$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <A,B,Out>
Graph<FanInShape2<A,B,Out>,NotUsed>create(Function2<A,B,Out> f)Create a newZipLatestWithvertex with the specified input types and zipping-functionf.<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>create10(Function10<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,Out> f)Create a newZipLatestWithspecialized for 10 inputs.<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>create11(Function11<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,Out> f)Create a newZipLatestWithspecialized for 11 inputs.<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>create12(Function12<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,Out> f)Create a newZipLatestWithspecialized for 12 inputs.<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>create13(Function13<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,Out> f)Create a newZipLatestWithspecialized for 13 inputs.<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>create14(Function14<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,Out> f)Create a newZipLatestWithspecialized for 14 inputs.<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>create15(Function15<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,Out> f)Create a newZipLatestWithspecialized for 15 inputs.<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>create16(Function16<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,Out> f)Create a newZipLatestWithspecialized for 16 inputs.<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>create17(Function17<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,Out> f)Create a newZipLatestWithspecialized for 17 inputs.<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>create18(Function18<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,Out> f)Create a newZipLatestWithspecialized for 18 inputs.<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>create19(Function19<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,Out> f)Create a newZipLatestWithspecialized for 19 inputs.<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>create20(Function20<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,Out> f)Create a newZipLatestWithspecialized for 20 inputs.<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>create21(Function21<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,Out> f)Create a newZipLatestWithspecialized for 21 inputs.<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>create22(Function22<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,Out> f)Create a newZipLatestWithspecialized for 22 inputs.<T1,T2,T3,Out>
Graph<FanInShape3<T1,T2,T3,Out>,NotUsed>create3(Function3<T1,T2,T3,Out> f)Create a newZipLatestWithspecialized for 3 inputs.<T1,T2,T3,T4,Out>
Graph<FanInShape4<T1,T2,T3,T4,Out>,NotUsed>create4(Function4<T1,T2,T3,T4,Out> f)Create a newZipLatestWithspecialized for 4 inputs.<T1,T2,T3,T4,T5,Out>
Graph<FanInShape5<T1,T2,T3,T4,T5,Out>,NotUsed>create5(Function5<T1,T2,T3,T4,T5,Out> f)Create a newZipLatestWithspecialized for 5 inputs.<T1,T2,T3,T4,T5,T6,Out>
Graph<FanInShape6<T1,T2,T3,T4,T5,T6,Out>,NotUsed>create6(Function6<T1,T2,T3,T4,T5,T6,Out> f)Create a newZipLatestWithspecialized for 6 inputs.<T1,T2,T3,T4,T5,T6,T7,Out>
Graph<FanInShape7<T1,T2,T3,T4,T5,T6,T7,Out>,NotUsed>create7(Function7<T1,T2,T3,T4,T5,T6,T7,Out> f)Create a newZipLatestWithspecialized for 7 inputs.<T1,T2,T3,T4,T5,T6,T7,T8,Out>
Graph<FanInShape8<T1,T2,T3,T4,T5,T6,T7,T8,Out>,NotUsed>create8(Function8<T1,T2,T3,T4,T5,T6,T7,T8,Out> f)Create a newZipLatestWithspecialized for 8 inputs.<T1,T2,T3,T4,T5,T6,T7,T8,T9,Out>
Graph<FanInShape9<T1,T2,T3,T4,T5,T6,T7,T8,T9,Out>,NotUsed>create9(Function9<T1,T2,T3,T4,T5,T6,T7,T8,T9,Out> f)Create a newZipLatestWithspecialized for 9 inputs.
-
-
-
Field Detail
-
MODULE$
public static final ZipLatestWith$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
create
public <A,B,Out> Graph<FanInShape2<A,B,Out>,NotUsed> create(Function2<A,B,Out> f)
Create a newZipLatestWithvertex with the specified input types and zipping-functionf.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create3
public <T1,T2,T3,Out> Graph<FanInShape3<T1,T2,T3,Out>,NotUsed> create3(Function3<T1,T2,T3,Out> f)
Create a newZipLatestWithspecialized for 3 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create4
public <T1,T2,T3,T4,Out> Graph<FanInShape4<T1,T2,T3,T4,Out>,NotUsed> create4(Function4<T1,T2,T3,T4,Out> f)
Create a newZipLatestWithspecialized for 4 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create5
public <T1,T2,T3,T4,T5,Out> Graph<FanInShape5<T1,T2,T3,T4,T5,Out>,NotUsed> create5(Function5<T1,T2,T3,T4,T5,Out> f)
Create a newZipLatestWithspecialized for 5 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create6
public <T1,T2,T3,T4,T5,T6,Out> Graph<FanInShape6<T1,T2,T3,T4,T5,T6,Out>,NotUsed> create6(Function6<T1,T2,T3,T4,T5,T6,Out> f)
Create a newZipLatestWithspecialized for 6 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create7
public <T1,T2,T3,T4,T5,T6,T7,Out> Graph<FanInShape7<T1,T2,T3,T4,T5,T6,T7,Out>,NotUsed> create7(Function7<T1,T2,T3,T4,T5,T6,T7,Out> f)
Create a newZipLatestWithspecialized for 7 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create8
public <T1,T2,T3,T4,T5,T6,T7,T8,Out> Graph<FanInShape8<T1,T2,T3,T4,T5,T6,T7,T8,Out>,NotUsed> create8(Function8<T1,T2,T3,T4,T5,T6,T7,T8,Out> f)
Create a newZipLatestWithspecialized for 8 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create9
public <T1,T2,T3,T4,T5,T6,T7,T8,T9,Out> Graph<FanInShape9<T1,T2,T3,T4,T5,T6,T7,T8,T9,Out>,NotUsed> create9(Function9<T1,T2,T3,T4,T5,T6,T7,T8,T9,Out> f)
Create a newZipLatestWithspecialized for 9 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create10
public <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> create10(Function10<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,Out> f)
Create a newZipLatestWithspecialized for 10 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create11
public <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> create11(Function11<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,Out> f)
Create a newZipLatestWithspecialized for 11 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create12
public <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> create12(Function12<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,Out> f)
Create a newZipLatestWithspecialized for 12 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create13
public <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> create13(Function13<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,Out> f)
Create a newZipLatestWithspecialized for 13 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create14
public <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> create14(Function14<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,Out> f)
Create a newZipLatestWithspecialized for 14 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create15
public <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> create15(Function15<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,Out> f)
Create a newZipLatestWithspecialized for 15 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create16
public <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> create16(Function16<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,Out> f)
Create a newZipLatestWithspecialized for 16 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create17
public <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> create17(Function17<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,Out> f)
Create a newZipLatestWithspecialized for 17 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create18
public <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> create18(Function18<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,Out> f)
Create a newZipLatestWithspecialized for 18 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create19
public <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> create19(Function19<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,Out> f)
Create a newZipLatestWithspecialized for 19 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create20
public <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> create20(Function20<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,Out> f)
Create a newZipLatestWithspecialized for 20 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create21
public <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> create21(Function21<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,Out> f)
Create a newZipLatestWithspecialized for 21 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create22
public <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> create22(Function22<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,Out> f)
Create a newZipLatestWithspecialized for 22 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
-