Package org.apache.pekko.stream.javadsl

Class UnzipWith

java.lang.Object

org.apache.pekko.stream.javadsl.UnzipWith

public class UnzipWith
extends Object

Split one stream into several streams using a splitting function.

'''Emits when''' all of the outputs stops backpressuring and there is an input element available

'''Backpressures when''' any of the outputs backpressures

'''Completes when''' upstream completes

'''Cancels when''' any downstream cancels

Constructor Summary

Constructors

Constructor	Description
UnzipWith()

Method Summary

Modifier and Type	Method	Description
static <In, A, B> Graph<FanOutShape2<In,A,B>,NotUsed>	create(Function<In,Pair<A,B>> f)	Create a new UnzipWith vertex with the specified input type and unzipping-function f.
static <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10> Graph<FanOutShape10<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10>,NotUsed>	create10(Function<In,Tuple10<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10>> f)	Create a new UnzipWith specialized for 10 outputs.
static <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11> Graph<FanOutShape11<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11>,NotUsed>	create11(Function<In,Tuple11<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11>> f)	Create a new UnzipWith specialized for 11 outputs.
static <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12> Graph<FanOutShape12<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12>,NotUsed>	create12(Function<In,Tuple12<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12>> f)	Create a new UnzipWith specialized for 12 outputs.
static <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13> Graph<FanOutShape13<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13>,NotUsed>	create13(Function<In,Tuple13<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13>> f)	Create a new UnzipWith specialized for 13 outputs.
static <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14> Graph<FanOutShape14<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14>,NotUsed>	create14(Function<In,Tuple14<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14>> f)	Create a new UnzipWith specialized for 14 outputs.
static <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15> Graph<FanOutShape15<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15>,NotUsed>	create15(Function<In,Tuple15<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15>> f)	Create a new UnzipWith specialized for 15 outputs.
static <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16> Graph<FanOutShape16<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16>,NotUsed>	create16(Function<In,Tuple16<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16>> f)	Create a new UnzipWith specialized for 16 outputs.
static <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17> Graph<FanOutShape17<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17>,NotUsed>	create17(Function<In,Tuple17<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17>> f)	Create a new UnzipWith specialized for 17 outputs.
static <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18> Graph<FanOutShape18<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18>,NotUsed>	create18(Function<In,Tuple18<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18>> f)	Create a new UnzipWith specialized for 18 outputs.
static <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19> Graph<FanOutShape19<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19>,NotUsed>	create19(Function<In,Tuple19<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19>> f)	Create a new UnzipWith specialized for 19 outputs.
static <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20> Graph<FanOutShape20<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20>,NotUsed>	create20(Function<In,Tuple20<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20>> f)	Create a new UnzipWith specialized for 20 outputs.
static <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21> Graph<FanOutShape21<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21>,NotUsed>	create21(Function<In,Tuple21<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21>> f)	Create a new UnzipWith specialized for 21 outputs.
static <In, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, T22> Graph<FanOutShape22<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22>,NotUsed>	create22(Function<In,Tuple22<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22>> f)	Create a new UnzipWith specialized for 22 outputs.
static <In, T1, T2, T3> Graph<FanOutShape3<In,T1,T2,T3>,NotUsed>	create3(Function<In,Tuple3<T1,T2,T3>> f)	Create a new UnzipWith specialized for 3 outputs.
static <In, T1, T2, T3, T4> Graph<FanOutShape4<In,T1,T2,T3,T4>,NotUsed>	create4(Function<In,Tuple4<T1,T2,T3,T4>> f)	Create a new UnzipWith specialized for 4 outputs.
static <In, T1, T2, T3, T4, T5> Graph<FanOutShape5<In,T1,T2,T3,T4,T5>,NotUsed>	create5(Function<In,Tuple5<T1,T2,T3,T4,T5>> f)	Create a new UnzipWith specialized for 5 outputs.
static <In, T1, T2, T3, T4, T5, T6> Graph<FanOutShape6<In,T1,T2,T3,T4,T5,T6>,NotUsed>	create6(Function<In,Tuple6<T1,T2,T3,T4,T5,T6>> f)	Create a new UnzipWith specialized for 6 outputs.
static <In, T1, T2, T3, T4, T5, T6, T7> Graph<FanOutShape7<In,T1,T2,T3,T4,T5,T6,T7>,NotUsed>	create7(Function<In,Tuple7<T1,T2,T3,T4,T5,T6,T7>> f)	Create a new UnzipWith specialized for 7 outputs.
static <In, T1, T2, T3, T4, T5, T6, T7, T8> Graph<FanOutShape8<In,T1,T2,T3,T4,T5,T6,T7,T8>,NotUsed>	create8(Function<In,Tuple8<T1,T2,T3,T4,T5,T6,T7,T8>> f)	Create a new UnzipWith specialized for 8 outputs.
static <In, T1, T2, T3, T4, T5, T6, T7, T8, T9> Graph<FanOutShape9<In,T1,T2,T3,T4,T5,T6,T7,T8,T9>,NotUsed>	create9(Function<In,Tuple9<T1,T2,T3,T4,T5,T6,T7,T8,T9>> f)	Create a new UnzipWith specialized for 9 outputs.

Methods inherited from class java.lang.Object

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

Constructor Details

UnzipWith

public UnzipWith()

Method Details

create

public static <In,
A,
B>
Graph<FanOutShape2<In,A,B>,NotUsed> create(Function<In,Pair<A,B>> f)

Create a new UnzipWith vertex with the specified input type and unzipping-function f.

Parameters:

f - unzipping-function from the input value to the pair of output values

create3

public static <In,
T1,
T2,
T3>
Graph<FanOutShape3<In,T1,T2,T3>,NotUsed> create3(Function<In,Tuple3<T1,T2,T3>> f)

Create a new UnzipWith specialized for 3 outputs.

Parameters:

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

create4

public static <In,
T1,
T2,
T3,
T4>
Graph<FanOutShape4<In,T1,T2,T3,T4>,NotUsed> create4(Function<In,Tuple4<T1,T2,T3,T4>> f)

Create a new UnzipWith specialized for 4 outputs.

Parameters:

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

create5

public static <In,
T1,
T2,
T3,
T4,
T5>
Graph<FanOutShape5<In,T1,T2,T3,T4,T5>,NotUsed> create5(Function<In,Tuple5<T1,T2,T3,T4,T5>> f)

Create a new UnzipWith specialized for 5 outputs.

Parameters:

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

create6

public static <In,
T1,
T2,
T3,
T4,
T5,
T6>
Graph<FanOutShape6<In,T1,T2,T3,T4,T5,T6>,NotUsed> create6(Function<In,Tuple6<T1,T2,T3,T4,T5,T6>> f)

Create a new UnzipWith specialized for 6 outputs.

Parameters:

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

create7

public static <In,
T1,
T2,
T3,
T4,
T5,
T6,
T7>
Graph<FanOutShape7<In,T1,T2,T3,T4,T5,T6,T7>,NotUsed> create7(Function<In,Tuple7<T1,T2,T3,T4,T5,T6,T7>> f)

Create a new UnzipWith specialized for 7 outputs.

Parameters:

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

create8

public static <In,
T1,
T2,
T3,
T4,
T5,
T6,
T7,
T8>
Graph<FanOutShape8<In,T1,T2,T3,T4,T5,T6,T7,T8>,NotUsed> create8(Function<In,Tuple8<T1,T2,T3,T4,T5,T6,T7,T8>> f)

Create a new UnzipWith specialized for 8 outputs.

Parameters:

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

create9

public static <In,
T1,
T2,
T3,
T4,
T5,
T6,
T7,
T8,
T9>
Graph<FanOutShape9<In,T1,T2,T3,T4,T5,T6,T7,T8,T9>,NotUsed> create9(Function<In,Tuple9<T1,T2,T3,T4,T5,T6,T7,T8,T9>> f)

Create a new UnzipWith specialized for 9 outputs.

Parameters:

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

create10

public static <In,
T1,
T2,
T3,
T4,
T5,
T6,
T7,
T8,
T9,
T10>
Graph<FanOutShape10<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10>,NotUsed> create10(Function<In,Tuple10<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10>> f)

Create a new UnzipWith specialized for 10 outputs.

Parameters:

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

create11

public static <In,
T1,
T2,
T3,
T4,
T5,
T6,
T7,
T8,
T9,
T10,
T11>
Graph<FanOutShape11<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11>,NotUsed> create11(Function<In,Tuple11<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11>> f)

Create a new UnzipWith specialized for 11 outputs.

Parameters:

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

create12

public static <In,
T1,
T2,
T3,
T4,
T5,
T6,
T7,
T8,
T9,
T10,
T11,
T12>
Graph<FanOutShape12<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12>,NotUsed> create12(Function<In,Tuple12<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12>> f)

Create a new UnzipWith specialized for 12 outputs.

Parameters:

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

create13

public static <In,
T1,
T2,
T3,
T4,
T5,
T6,
T7,
T8,
T9,
T10,
T11,
T12,
T13>
Graph<FanOutShape13<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13>,NotUsed> create13(Function<In,Tuple13<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13>> f)

Create a new UnzipWith specialized for 13 outputs.

Parameters:

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

create14

public static <In,
T1,
T2,
T3,
T4,
T5,
T6,
T7,
T8,
T9,
T10,
T11,
T12,
T13,
T14>
Graph<FanOutShape14<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14>,NotUsed> create14(Function<In,Tuple14<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14>> f)

Create a new UnzipWith specialized for 14 outputs.

Parameters:

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

create15

public static <In,
T1,
T2,
T3,
T4,
T5,
T6,
T7,
T8,
T9,
T10,
T11,
T12,
T13,
T14,
T15>
Graph<FanOutShape15<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15>,NotUsed> create15(Function<In,Tuple15<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15>> f)

Create a new UnzipWith specialized for 15 outputs.

Parameters:

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

create16

public static <In,
T1,
T2,
T3,
T4,
T5,
T6,
T7,
T8,
T9,
T10,
T11,
T12,
T13,
T14,
T15,
T16>
Graph<FanOutShape16<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16>,NotUsed> create16(Function<In,Tuple16<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16>> f)

Create a new UnzipWith specialized for 16 outputs.

Parameters:

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

create17

public static <In,
T1,
T2,
T3,
T4,
T5,
T6,
T7,
T8,
T9,
T10,
T11,
T12,
T13,
T14,
T15,
T16,
T17>
Graph<FanOutShape17<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17>,NotUsed> create17(Function<In,Tuple17<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17>> f)

Create a new UnzipWith specialized for 17 outputs.

Parameters:

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

create18

public static <In,
T1,
T2,
T3,
T4,
T5,
T6,
T7,
T8,
T9,
T10,
T11,
T12,
T13,
T14,
T15,
T16,
T17,
T18>
Graph<FanOutShape18<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18>,NotUsed> create18(Function<In,Tuple18<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18>> f)

Create a new UnzipWith specialized for 18 outputs.

Parameters:

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

create19

public static <In,
T1,
T2,
T3,
T4,
T5,
T6,
T7,
T8,
T9,
T10,
T11,
T12,
T13,
T14,
T15,
T16,
T17,
T18,
T19>
Graph<FanOutShape19<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19>,NotUsed> create19(Function<In,Tuple19<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19>> f)

Create a new UnzipWith specialized for 19 outputs.

Parameters:

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

create20

public static <In,
T1,
T2,
T3,
T4,
T5,
T6,
T7,
T8,
T9,
T10,
T11,
T12,
T13,
T14,
T15,
T16,
T17,
T18,
T19,
T20>
Graph<FanOutShape20<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20>,NotUsed> create20(Function<In,Tuple20<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20>> f)

Create a new UnzipWith specialized for 20 outputs.

Parameters:

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

create21

public static <In,
T1,
T2,
T3,
T4,
T5,
T6,
T7,
T8,
T9,
T10,
T11,
T12,
T13,
T14,
T15,
T16,
T17,
T18,
T19,
T20,
T21>
Graph<FanOutShape21<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21>,NotUsed> create21(Function<In,Tuple21<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21>> f)

Create a new UnzipWith specialized for 21 outputs.

Parameters:

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

create22

public static <In,
T1,
T2,
T3,
T4,
T5,
T6,
T7,
T8,
T9,
T10,
T11,
T12,
T13,
T14,
T15,
T16,
T17,
T18,
T19,
T20,
T21,
T22>
Graph<FanOutShape22<In,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22>,NotUsed> create22(Function<In,Tuple22<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22>> f)

Create a new UnzipWith specialized for 22 outputs.

Parameters:

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