public class UnzipWith
extends java.lang.Object
'''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 and Description |
---|
UnzipWith() |
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> |
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> |
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> |
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> |
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> |
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> |
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> |
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> |
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> |
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> |
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> |
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> |
create3(Function<In,Tuple3<T1,T2,T3>> f)
Create a new
UnzipWith specialized for 3 outputs. |
static <In,T1,T2,T3,T4> |
create4(Function<In,Tuple4<T1,T2,T3,T4>> f)
Create a new
UnzipWith specialized for 4 outputs. |
static <In,T1,T2,T3,T4,T5> |
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> |
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> |
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> |
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> |
create9(Function<In,Tuple9<T1,T2,T3,T4,T5,T6,T7,T8,T9>> f)
Create a new
UnzipWith specialized for 9 outputs. |
public static <In,A,B> Graph<FanOutShape2<In,A,B>,NotUsed> create(Function<In,Pair<A,B>> f)
UnzipWith
vertex with the specified input type and unzipping-function f
.
f
- unzipping-function from the input value to the pair of output valuespublic static <In,T1,T2,T3> Graph<FanOutShape3<In,T1,T2,T3>,NotUsed> create3(Function<In,Tuple3<T1,T2,T3>> f)
UnzipWith
specialized for 3 outputs.
f
- unzipping-function from the input value to the output valuespublic static <In,T1,T2,T3,T4> Graph<FanOutShape4<In,T1,T2,T3,T4>,NotUsed> create4(Function<In,Tuple4<T1,T2,T3,T4>> f)
UnzipWith
specialized for 4 outputs.
f
- unzipping-function from the input value to the output valuespublic 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)
UnzipWith
specialized for 5 outputs.
f
- unzipping-function from the input value to the output valuespublic 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)
UnzipWith
specialized for 6 outputs.
f
- unzipping-function from the input value to the output valuespublic 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)
UnzipWith
specialized for 7 outputs.
f
- unzipping-function from the input value to the output valuespublic 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)
UnzipWith
specialized for 8 outputs.
f
- unzipping-function from the input value to the output valuespublic 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)
UnzipWith
specialized for 9 outputs.
f
- unzipping-function from the input value to the output valuespublic 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)
UnzipWith
specialized for 10 outputs.
f
- unzipping-function from the input value to the output valuespublic 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)
UnzipWith
specialized for 11 outputs.
f
- unzipping-function from the input value to the output valuespublic 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)
UnzipWith
specialized for 12 outputs.
f
- unzipping-function from the input value to the output valuespublic 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)
UnzipWith
specialized for 13 outputs.
f
- unzipping-function from the input value to the output valuespublic 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)
UnzipWith
specialized for 14 outputs.
f
- unzipping-function from the input value to the output valuespublic 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)
UnzipWith
specialized for 15 outputs.
f
- unzipping-function from the input value to the output valuespublic 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)
UnzipWith
specialized for 16 outputs.
f
- unzipping-function from the input value to the output valuespublic 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)
UnzipWith
specialized for 17 outputs.
f
- unzipping-function from the input value to the output valuespublic 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)
UnzipWith
specialized for 18 outputs.
f
- unzipping-function from the input value to the output valuespublic 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)
UnzipWith
specialized for 19 outputs.
f
- unzipping-function from the input value to the output valuespublic 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)
UnzipWith
specialized for 20 outputs.
f
- unzipping-function from the input value to the output values