Package akka.stream.javadsl
Class ZipWith
- java.lang.Object
-
- akka.stream.javadsl.ZipWith
-
public class ZipWith extends java.lang.Object
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
-
-
Constructor Summary
Constructors Constructor Description ZipWith()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <A,B,Out>
Graph<FanInShape2<A,B,Out>,NotUsed>create(Function2<A,B,Out> f)
Create a newZipWith
vertex with the specified input types and zipping-functionf
.static <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 newZipWith
specialized for 10 inputs.static <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 newZipWith
specialized for 11 inputs.static <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 newZipWith
specialized for 12 inputs.static <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 newZipWith
specialized for 13 inputs.static <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 newZipWith
specialized for 14 inputs.static <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 newZipWith
specialized for 15 inputs.static <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 newZipWith
specialized for 16 inputs.static <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 newZipWith
specialized for 17 inputs.static <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 newZipWith
specialized for 18 inputs.static <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 newZipWith
specialized for 19 inputs.static <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 newZipWith
specialized for 20 inputs.static <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 newZipWith
specialized for 21 inputs.static <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 newZipWith
specialized for 22 inputs.static <T1,T2,T3,Out>
Graph<FanInShape3<T1,T2,T3,Out>,NotUsed>create3(Function3<T1,T2,T3,Out> f)
Create a newZipWith
specialized for 3 inputs.static <T1,T2,T3,T4,Out>
Graph<FanInShape4<T1,T2,T3,T4,Out>,NotUsed>create4(Function4<T1,T2,T3,T4,Out> f)
Create a newZipWith
specialized for 4 inputs.static <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 newZipWith
specialized for 5 inputs.static <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 newZipWith
specialized for 6 inputs.static <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 newZipWith
specialized for 7 inputs.static <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 newZipWith
specialized for 8 inputs.static <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 newZipWith
specialized for 9 inputs.
-
-
-
Method Detail
-
create
public static <A,B,Out> Graph<FanInShape2<A,B,Out>,NotUsed> create(Function2<A,B,Out> f)
Create a newZipWith
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 static <T1,T2,T3,Out> Graph<FanInShape3<T1,T2,T3,Out>,NotUsed> create3(Function3<T1,T2,T3,Out> f)
Create a newZipWith
specialized for 3 inputs.- Parameters:
f
- zipping-function from the input values to the output valueattributes
- optional attributes for this vertex
-
create4
public static <T1,T2,T3,T4,Out> Graph<FanInShape4<T1,T2,T3,T4,Out>,NotUsed> create4(Function4<T1,T2,T3,T4,Out> f)
Create a newZipWith
specialized for 4 inputs.- Parameters:
f
- zipping-function from the input values to the output valueattributes
- optional attributes for this vertex
-
create5
public static <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 newZipWith
specialized for 5 inputs.- Parameters:
f
- zipping-function from the input values to the output valueattributes
- optional attributes for this vertex
-
create6
public static <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 newZipWith
specialized for 6 inputs.- Parameters:
f
- zipping-function from the input values to the output valueattributes
- optional attributes for this vertex
-
create7
public static <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 newZipWith
specialized for 7 inputs.- Parameters:
f
- zipping-function from the input values to the output valueattributes
- optional attributes for this vertex
-
create8
public static <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 newZipWith
specialized for 8 inputs.- Parameters:
f
- zipping-function from the input values to the output valueattributes
- optional attributes for this vertex
-
create9
public static <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 newZipWith
specialized for 9 inputs.- Parameters:
f
- zipping-function from the input values to the output valueattributes
- optional attributes for this vertex
-
create10
public static <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 newZipWith
specialized for 10 inputs.- Parameters:
f
- zipping-function from the input values to the output valueattributes
- optional attributes for this vertex
-
create11
public static <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 newZipWith
specialized for 11 inputs.- Parameters:
f
- zipping-function from the input values to the output valueattributes
- optional attributes for this vertex
-
create12
public static <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 newZipWith
specialized for 12 inputs.- Parameters:
f
- zipping-function from the input values to the output valueattributes
- optional attributes for this vertex
-
create13
public static <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 newZipWith
specialized for 13 inputs.- Parameters:
f
- zipping-function from the input values to the output valueattributes
- optional attributes for this vertex
-
create14
public static <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 newZipWith
specialized for 14 inputs.- Parameters:
f
- zipping-function from the input values to the output valueattributes
- optional attributes for this vertex
-
create15
public static <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 newZipWith
specialized for 15 inputs.- Parameters:
f
- zipping-function from the input values to the output valueattributes
- optional attributes for this vertex
-
create16
public static <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 newZipWith
specialized for 16 inputs.- Parameters:
f
- zipping-function from the input values to the output valueattributes
- optional attributes for this vertex
-
create17
public static <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 newZipWith
specialized for 17 inputs.- Parameters:
f
- zipping-function from the input values to the output valueattributes
- optional attributes for this vertex
-
create18
public static <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 newZipWith
specialized for 18 inputs.- Parameters:
f
- zipping-function from the input values to the output valueattributes
- optional attributes for this vertex
-
create19
public static <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 newZipWith
specialized for 19 inputs.- Parameters:
f
- zipping-function from the input values to the output valueattributes
- optional attributes for this vertex
-
create20
public static <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 newZipWith
specialized for 20 inputs.- Parameters:
f
- zipping-function from the input values to the output valueattributes
- optional attributes for this vertex
-
create21
public static <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 newZipWith
specialized for 21 inputs.- Parameters:
f
- zipping-function from the input values to the output valueattributes
- optional attributes for this vertex
-
create22
public static <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 newZipWith
specialized for 22 inputs.- Parameters:
f
- zipping-function from the input values to the output valueattributes
- optional attributes for this vertex
-
-