Package akka.stream.javadsl
Class UnzipWith$
- java.lang.Object
-
- akka.stream.javadsl.UnzipWith$
-
public class UnzipWith$ extends java.lang.ObjectSplit 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 newUnzipWithvertex 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized for 22 outputs.<In,T1,T2,T3>
Graph<FanOutShape3<In,T1,T2,T3>,NotUsed>create3(Function<In,Tuple3<T1,T2,T3>> f)Create a newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithvertex 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized 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 newUnzipWithspecialized for 22 outputs.- Parameters:
f- unzipping-function from the input value to the output values
-
-