Package 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 Description static UnzipWith$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description UnzipWith$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <In,A,B>
Graph<FanOutShape2<In,A,B>,NotUsed>create(Function<In,Pair<A,B>> f)
Create a newUnzipWith
vertex with the specified input type and unzipping-functionf
.<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 newUnzipWith
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 newUnzipWith
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 newUnzipWith
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 newUnzipWith
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 newUnzipWith
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 newUnzipWith
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 newUnzipWith
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 newUnzipWith
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 newUnzipWith
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 newUnzipWith
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 newUnzipWith
specialized for 20 outputs.<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 newUnzipWith
specialized for 21 outputs.<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 newUnzipWith
specialized for 22 outputs.<In,T1,T2,T3>
Graph<FanOutShape3<In,T1,T2,T3>,NotUsed>create3(Function<In,Tuple3<T1,T2,T3>> f)
Create a newUnzipWith
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 newUnzipWith
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 newUnzipWith
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 newUnzipWith
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 newUnzipWith
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 newUnzipWith
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 newUnzipWith
specialized for 9 outputs.
-
-
-
Field Detail
-
MODULE$
public static final UnzipWith$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
create
public <In,A,B> Graph<FanOutShape2<In,A,B>,NotUsed> create(Function<In,Pair<A,B>> f)
Create a newUnzipWith
vertex with the specified input type and unzipping-functionf
.- Parameters:
f
- unzipping-function from the input value to the pair of output values
-
create3
public <In,T1,T2,T3> Graph<FanOutShape3<In,T1,T2,T3>,NotUsed> create3(Function<In,Tuple3<T1,T2,T3>> f)
Create a newUnzipWith
specialized for 3 outputs.- Parameters:
f
- unzipping-function from the input value to the output values
-
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 newUnzipWith
specialized for 4 outputs.- Parameters:
f
- unzipping-function from the input value to the output values
-
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 newUnzipWith
specialized for 5 outputs.- Parameters:
f
- unzipping-function from the input value to the output values
-
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 newUnzipWith
specialized for 6 outputs.- Parameters:
f
- unzipping-function from the input value to the output values
-
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 newUnzipWith
specialized for 7 outputs.- Parameters:
f
- unzipping-function from the input value to the output values
-
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 newUnzipWith
specialized for 8 outputs.- Parameters:
f
- unzipping-function from the input value to the output values
-
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 newUnzipWith
specialized for 9 outputs.- Parameters:
f
- unzipping-function from the input value to the output values
-
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 newUnzipWith
specialized for 10 outputs.- Parameters:
f
- unzipping-function from the input value to the output values
-
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 newUnzipWith
specialized for 11 outputs.- Parameters:
f
- unzipping-function from the input value to the output values
-
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 newUnzipWith
specialized for 12 outputs.- Parameters:
f
- unzipping-function from the input value to the output values
-
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 newUnzipWith
specialized for 13 outputs.- Parameters:
f
- unzipping-function from the input value to the output values
-
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 newUnzipWith
specialized for 14 outputs.- Parameters:
f
- unzipping-function from the input value to the output values
-
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 newUnzipWith
specialized for 15 outputs.- Parameters:
f
- unzipping-function from the input value to the output values
-
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 newUnzipWith
specialized for 16 outputs.- Parameters:
f
- unzipping-function from the input value to the output values
-
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 newUnzipWith
specialized for 17 outputs.- Parameters:
f
- unzipping-function from the input value to the output values
-
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 newUnzipWith
specialized for 18 outputs.- Parameters:
f
- unzipping-function from the input value to the output values
-
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 newUnzipWith
specialized for 19 outputs.- Parameters:
f
- unzipping-function from the input value to the output values
-
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 newUnzipWith
specialized for 20 outputs.- Parameters:
f
- unzipping-function from the input value to the output values
-
create21
public <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 newUnzipWith
specialized for 21 outputs.- Parameters:
f
- unzipping-function from the input value to the output values
-
create22
public <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 newUnzipWith
specialized for 22 outputs.- Parameters:
f
- unzipping-function from the input value to the output values
-
-