Package org.apache.pekko.stream.javadsl
Class ZipWith$
java.lang.Object
org.apache.pekko.stream.javadsl.ZipWith$
Combine the elements of multiple streams into a stream of combined elements using a combiner function.
'''Emits when''' all of the inputs has an element available
'''Backpressures when''' downstream backpressures
'''Completes when''' any upstream completes
'''Cancels when''' downstream cancels
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescription<A,B, Out> Graph<FanInShape2<A, B, Out>, NotUsed> Create a newZipWithvertex with the specified input types and zipping-functionf.<T1,T2, T3, T4, T5, T6, T7, T8, T9, T10, Out>
Graph<FanInShape10<T1,T2, T3, T4, T5, T6, T7, T8, T9, T10, Out>, NotUsed> create10(Function10<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, Out> f) Create a newZipWithspecialized for 10 inputs.<T1,T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, Out>
Graph<FanInShape11<T1,T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, Out>, NotUsed> create11(Function11<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, Out> f) Create a newZipWithspecialized for 11 inputs.<T1,T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, Out>
Graph<FanInShape12<T1,T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, Out>, NotUsed> create12(Function12<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, Out> f) Create a newZipWithspecialized for 12 inputs.<T1,T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, Out>
Graph<FanInShape13<T1,T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, Out>, NotUsed> create13(Function13<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, Out> f) Create a newZipWithspecialized for 13 inputs.<T1,T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, Out>
Graph<FanInShape14<T1,T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, Out>, NotUsed> create14(Function14<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, Out> f) Create a newZipWithspecialized for 14 inputs.<T1,T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, Out>
Graph<FanInShape15<T1,T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, Out>, NotUsed> create15(Function15<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, Out> f) Create a newZipWithspecialized for 15 inputs.<T1,T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, Out>
Graph<FanInShape16<T1,T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, Out>, NotUsed> create16(Function16<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, Out> f) Create a newZipWithspecialized for 16 inputs.<T1,T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, Out>
Graph<FanInShape17<T1,T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, Out>, NotUsed> create17(Function17<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, Out> f) Create a newZipWithspecialized for 17 inputs.<T1,T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, Out>
Graph<FanInShape18<T1,T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, Out>, NotUsed> create18(Function18<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, Out> f) Create a newZipWithspecialized for 18 inputs.<T1,T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, Out>
Graph<FanInShape19<T1,T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, Out>, NotUsed> create19(Function19<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, Out> f) Create a newZipWithspecialized for 19 inputs.<T1,T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, Out>
Graph<FanInShape20<T1,T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, Out>, NotUsed> create20(Function20<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, Out> f) Create a newZipWithspecialized for 20 inputs.<T1,T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, Out>
Graph<FanInShape21<T1,T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, Out>, NotUsed> create21(Function21<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, Out> f) Create a newZipWithspecialized for 21 inputs.<T1,T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, T22, Out>
Graph<FanInShape22<T1,T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, T22, Out>, NotUsed> create22(Function22<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, T22, Out> f) Create a newZipWithspecialized for 22 inputs.<T1,T2, T3, Out>
Graph<FanInShape3<T1,T2, T3, Out>, NotUsed> Create a newZipWithspecialized for 3 inputs.<T1,T2, T3, T4, Out>
Graph<FanInShape4<T1,T2, T3, T4, Out>, NotUsed> Create a newZipWithspecialized for 4 inputs.<T1,T2, T3, T4, T5, Out>
Graph<FanInShape5<T1,T2, T3, T4, T5, Out>, NotUsed> Create a newZipWithspecialized for 5 inputs.<T1,T2, T3, T4, T5, T6, Out>
Graph<FanInShape6<T1,T2, T3, T4, T5, T6, Out>, NotUsed> Create a newZipWithspecialized for 6 inputs.<T1,T2, T3, T4, T5, T6, T7, Out>
Graph<FanInShape7<T1,T2, T3, T4, T5, T6, T7, Out>, NotUsed> Create a newZipWithspecialized for 7 inputs.<T1,T2, T3, T4, T5, T6, T7, T8, Out>
Graph<FanInShape8<T1,T2, T3, T4, T5, T6, T7, T8, Out>, NotUsed> Create a newZipWithspecialized for 8 inputs.<T1,T2, T3, T4, T5, T6, T7, T8, T9, Out>
Graph<FanInShape9<T1,T2, T3, T4, T5, T6, T7, T8, T9, Out>, NotUsed> Create a newZipWithspecialized for 9 inputs.
-
Field Details
-
MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Constructor Details
-
ZipWith$
public ZipWith$()
-
-
Method Details
-
create
Create a newZipWithvertex with the specified input types and zipping-functionf.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create3
public <T1,T2, Graph<FanInShape3<T1,T3, Out> T2, create3T3, Out>, NotUsed> (Function3<T1, T2, T3, Out> f) Create a newZipWithspecialized for 3 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create4
public <T1,T2, Graph<FanInShape4<T1,T3, T4, Out> T2, create4T3, T4, Out>, NotUsed> (Function4<T1, T2, T3, T4, Out> f) Create a newZipWithspecialized for 4 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create5
public <T1,T2, Graph<FanInShape5<T1,T3, T4, T5, Out> T2, create5T3, T4, T5, Out>, NotUsed> (Function5<T1, T2, T3, T4, T5, Out> f) Create a newZipWithspecialized for 5 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create6
public <T1,T2, Graph<FanInShape6<T1,T3, T4, T5, T6, Out> T2, create6T3, T4, T5, T6, Out>, NotUsed> (Function6<T1, T2, T3, T4, T5, T6, Out> f) Create a newZipWithspecialized for 6 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create7
public <T1,T2, Graph<FanInShape7<T1,T3, T4, T5, T6, T7, Out> T2, create7T3, T4, T5, T6, T7, Out>, NotUsed> (Function7<T1, T2, T3, T4, T5, T6, T7, Out> f) Create a newZipWithspecialized for 7 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create8
public <T1,T2, Graph<FanInShape8<T1,T3, T4, T5, T6, T7, T8, Out> T2, create8T3, T4, T5, T6, T7, T8, Out>, NotUsed> (Function8<T1, T2, T3, T4, T5, T6, T7, T8, Out> f) Create a newZipWithspecialized for 8 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create9
public <T1,T2, Graph<FanInShape9<T1,T3, T4, T5, T6, T7, T8, T9, Out> T2, create9T3, T4, T5, T6, T7, T8, T9, Out>, NotUsed> (Function9<T1, T2, T3, T4, T5, T6, T7, T8, T9, Out> f) Create a newZipWithspecialized for 9 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create10
public <T1,T2, Graph<FanInShape10<T1,T3, T4, T5, T6, T7, T8, T9, T10, Out> T2, create10T3, T4, T5, T6, T7, T8, T9, T10, Out>, NotUsed> (Function10<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, Out> f) Create a newZipWithspecialized for 10 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create11
public <T1,T2, Graph<FanInShape11<T1,T3, T4, T5, T6, T7, T8, T9, T10, T11, Out> T2, create11T3, T4, T5, T6, T7, T8, T9, T10, T11, Out>, NotUsed> (Function11<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, Out> f) Create a newZipWithspecialized for 11 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create12
public <T1,T2, Graph<FanInShape12<T1,T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, Out> T2, create12T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, Out>, NotUsed> (Function12<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, Out> f) Create a newZipWithspecialized for 12 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create13
public <T1,T2, Graph<FanInShape13<T1,T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, Out> T2, create13T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, Out>, NotUsed> (Function13<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, Out> f) Create a newZipWithspecialized for 13 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create14
public <T1,T2, Graph<FanInShape14<T1,T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, Out> T2, create14T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, Out>, NotUsed> (Function14<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, Out> f) Create a newZipWithspecialized for 14 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create15
public <T1,T2, Graph<FanInShape15<T1,T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, Out> T2, create15T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, Out>, NotUsed> (Function15<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, Out> f) Create a newZipWithspecialized for 15 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create16
public <T1,T2, Graph<FanInShape16<T1,T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, Out> T2, create16T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, Out>, NotUsed> (Function16<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, Out> f) Create a newZipWithspecialized for 16 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create17
public <T1,T2, Graph<FanInShape17<T1,T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, Out> T2, create17T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, Out>, NotUsed> (Function17<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, Out> f) Create a newZipWithspecialized for 17 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create18
public <T1,T2, Graph<FanInShape18<T1,T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, Out> T2, create18T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, Out>, NotUsed> (Function18<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, Out> f) Create a newZipWithspecialized for 18 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create19
public <T1,T2, Graph<FanInShape19<T1,T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, Out> T2, create19T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, Out>, NotUsed> (Function19<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, Out> f) Create a newZipWithspecialized for 19 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create20
public <T1,T2, Graph<FanInShape20<T1,T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, Out> T2, create20T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, Out>, NotUsed> (Function20<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, Out> f) Create a newZipWithspecialized for 20 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create21
public <T1,T2, Graph<FanInShape21<T1,T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, Out> T2, create21T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, Out>, NotUsed> (Function21<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, Out> f) Create a newZipWithspecialized for 21 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-
create22
public <T1,T2, Graph<FanInShape22<T1,T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, T22, Out> T2, create22T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, T22, Out>, NotUsed> (Function22<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, T22, Out> f) Create a newZipWithspecialized for 22 inputs.- Parameters:
f- zipping-function from the input values to the output valueattributes- optional attributes for this vertex
-