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 and Description
ZipWith()

Method Summary

Modifier and Type	Method and 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,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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)