Package akka.stream.javadsl
Class ZipLatestWith$
- java.lang.Object
-
- akka.stream.javadsl.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
-
-
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 newZipLatestWith
vertex 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized for 22 inputs.<T1,T2,T3,Out>
Graph<FanInShape3<T1,T2,T3,Out>,NotUsed>create3(Function3<T1,T2,T3,Out> f)
Create a newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
vertex 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized 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 newZipLatestWith
specialized for 22 inputs.- Parameters:
f
- zipping-function from the input values to the output valueattributes
- optional attributes for this vertex
-
-