Package org.apache.pekko.stream.javadsl

Class ZipWith

java.lang.Object

org.apache.pekko.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

Modifier and Type	Method	Description
static <A,B,Out> Graph<FanInShape2<A,B,Out>,NotUsed>	create(Function2<A,B,Out> f)	Create a new ZipWith vertex with the specified input types and zipping-function f.
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 new ZipWith 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 new ZipWith 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 new ZipWith 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 new ZipWith 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 new ZipWith 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 new ZipWith 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 new ZipWith 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 new ZipWith 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 new ZipWith 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 new ZipWith 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 new ZipWith 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 new ZipWith 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 new ZipWith 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 new ZipWith 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 new ZipWith 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 new ZipWith 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 new ZipWith 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 new ZipWith 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 new ZipWith 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 new ZipWith specialized for 9 inputs.

Methods inherited from class java.lang.Object

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

Constructor Detail

ZipWith

public ZipWith()

Method Detail

create

public static <A,B,Out> Graph<FanInShape2<A,B,Out>,NotUsed> create(Function2<A,B,Out> f)

Create a new ZipWith vertex with the specified input types and zipping-function f.

Parameters:

f - zipping-function from the input values to the output value

attributes - 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 new ZipWith specialized for 3 inputs.

Parameters:

f - zipping-function from the input values to the output value

attributes - 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 new ZipWith specialized for 4 inputs.

Parameters:

f - zipping-function from the input values to the output value

attributes - 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 new ZipWith specialized for 5 inputs.

Parameters:

f - zipping-function from the input values to the output value

attributes - 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 new ZipWith specialized for 6 inputs.

Parameters:

f - zipping-function from the input values to the output value

attributes - 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 new ZipWith specialized for 7 inputs.

Parameters:

f - zipping-function from the input values to the output value

attributes - 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 new ZipWith specialized for 8 inputs.

Parameters:

f - zipping-function from the input values to the output value

attributes - 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 new ZipWith specialized for 9 inputs.

Parameters:

f - zipping-function from the input values to the output value

attributes - 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 new ZipWith specialized for 10 inputs.

Parameters:

f - zipping-function from the input values to the output value

attributes - 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 new ZipWith specialized for 11 inputs.

Parameters:

f - zipping-function from the input values to the output value

attributes - 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 new ZipWith specialized for 12 inputs.

Parameters:

f - zipping-function from the input values to the output value

attributes - 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 new ZipWith specialized for 13 inputs.

Parameters:

f - zipping-function from the input values to the output value

attributes - 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 new ZipWith specialized for 14 inputs.

Parameters:

f - zipping-function from the input values to the output value

attributes - 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 new ZipWith specialized for 15 inputs.

Parameters:

f - zipping-function from the input values to the output value

attributes - 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 new ZipWith specialized for 16 inputs.

Parameters:

f - zipping-function from the input values to the output value

attributes - 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 new ZipWith specialized for 17 inputs.

Parameters:

f - zipping-function from the input values to the output value

attributes - 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 new ZipWith specialized for 18 inputs.

Parameters:

f - zipping-function from the input values to the output value

attributes - 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 new ZipWith specialized for 19 inputs.

Parameters:

f - zipping-function from the input values to the output value

attributes - 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 new ZipWith specialized for 20 inputs.

Parameters:

f - zipping-function from the input values to the output value

attributes - 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 new ZipWith specialized for 21 inputs.

Parameters:

f - zipping-function from the input values to the output value

attributes - 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 new ZipWith specialized for 22 inputs.

Parameters:

f - zipping-function from the input values to the output value

attributes - optional attributes for this vertex