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

Field Summary

Fields

Modifier and Type	Field and Description
static UnzipWith$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
UnzipWith$()

Method Summary

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

Field Detail

MODULE$

public static final UnzipWith$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

UnzipWith$

public UnzipWith$()

Method Detail

create

public <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 <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 <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 <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 <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 <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 <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 <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 <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 <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 <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 <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 <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 <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 <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 <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 <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 <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 <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)