akka.stream.javadsl

Class UnzipWith

java.lang.Object

akka.stream.javadsl.UnzipWith

public class UnzipWith
extends java.lang.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 and Description
UnzipWith()

Method Summary

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

UnzipWith

public UnzipWith()

Method Detail

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)