Class ZipWith


  • public class ZipWith
    extends java.lang.Object
    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

    • Constructor Summary

      Constructors 
      Constructor Description
      ZipWith()  
    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static <A,​B,​Out>
      Graph<FanInShape2<A,​B,​Out>,​NotUsed>
      create​(Function2<A,​B,​Out> f)
      Create a new ZipWith vertex with the specified input types and zipping-function f.
      static <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 new ZipWith specialized for 10 inputs.
      static <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 new ZipWith specialized for 11 inputs.
      static <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 new ZipWith specialized for 12 inputs.
      static <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 new ZipWith specialized for 13 inputs.
      static <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 new ZipWith specialized for 14 inputs.
      static <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 new ZipWith specialized for 15 inputs.
      static <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 new ZipWith specialized for 16 inputs.
      static <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 new ZipWith specialized for 17 inputs.
      static <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 new ZipWith specialized for 18 inputs.
      static <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 new ZipWith specialized for 19 inputs.
      static <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 new ZipWith specialized for 20 inputs.
      static <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 new ZipWith specialized for 21 inputs.
      static <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 new ZipWith specialized for 22 inputs.
      static <T1,​T2,​T3,​Out>
      Graph<FanInShape3<T1,​T2,​T3,​Out>,​NotUsed>
      create3​(Function3<T1,​T2,​T3,​Out> f)
      Create a new ZipWith specialized for 3 inputs.
      static <T1,​T2,​T3,​T4,​Out>
      Graph<FanInShape4<T1,​T2,​T3,​T4,​Out>,​NotUsed>
      create4​(Function4<T1,​T2,​T3,​T4,​Out> f)
      Create a new ZipWith specialized for 4 inputs.
      static <T1,​T2,​T3,​T4,​T5,​Out>
      Graph<FanInShape5<T1,​T2,​T3,​T4,​T5,​Out>,​NotUsed>
      create5​(Function5<T1,​T2,​T3,​T4,​T5,​Out> f)
      Create a new ZipWith specialized for 5 inputs.
      static <T1,​T2,​T3,​T4,​T5,​T6,​Out>
      Graph<FanInShape6<T1,​T2,​T3,​T4,​T5,​T6,​Out>,​NotUsed>
      create6​(Function6<T1,​T2,​T3,​T4,​T5,​T6,​Out> f)
      Create a new ZipWith specialized for 6 inputs.
      static <T1,​T2,​T3,​T4,​T5,​T6,​T7,​Out>
      Graph<FanInShape7<T1,​T2,​T3,​T4,​T5,​T6,​T7,​Out>,​NotUsed>
      create7​(Function7<T1,​T2,​T3,​T4,​T5,​T6,​T7,​Out> f)
      Create a new ZipWith specialized for 7 inputs.
      static <T1,​T2,​T3,​T4,​T5,​T6,​T7,​T8,​Out>
      Graph<FanInShape8<T1,​T2,​T3,​T4,​T5,​T6,​T7,​T8,​Out>,​NotUsed>
      create8​(Function8<T1,​T2,​T3,​T4,​T5,​T6,​T7,​T8,​Out> f)
      Create a new ZipWith specialized for 8 inputs.
      static <T1,​T2,​T3,​T4,​T5,​T6,​T7,​T8,​T9,​Out>
      Graph<FanInShape9<T1,​T2,​T3,​T4,​T5,​T6,​T7,​T8,​T9,​Out>,​NotUsed>
      create9​(Function9<T1,​T2,​T3,​T4,​T5,​T6,​T7,​T8,​T9,​Out> f)
      Create a new ZipWith specialized for 9 inputs.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • ZipWith

        public ZipWith()
    • Method Detail

      • create

        public static <A,​B,​Out> Graph<FanInShape2<A,​B,​Out>,​NotUsed> create​(Function2<A,​B,​Out> f)
        Create a new ZipWith vertex with the specified input types and zipping-function f.

        Parameters:
        f - zipping-function from the input values to the output value
        attributes - optional attributes for this vertex
      • create3

        public static <T1,​T2,​T3,​Out> Graph<FanInShape3<T1,​T2,​T3,​Out>,​NotUsed> create3​(Function3<T1,​T2,​T3,​Out> f)
        Create a new ZipWith specialized for 3 inputs.

        Parameters:
        f - zipping-function from the input values to the output value
        attributes - optional attributes for this vertex
      • create4

        public static <T1,​T2,​T3,​T4,​Out> Graph<FanInShape4<T1,​T2,​T3,​T4,​Out>,​NotUsed> create4​(Function4<T1,​T2,​T3,​T4,​Out> f)
        Create a new ZipWith specialized for 4 inputs.

        Parameters:
        f - zipping-function from the input values to the output value
        attributes - optional attributes for this vertex
      • create5

        public static <T1,​T2,​T3,​T4,​T5,​Out> Graph<FanInShape5<T1,​T2,​T3,​T4,​T5,​Out>,​NotUsed> create5​(Function5<T1,​T2,​T3,​T4,​T5,​Out> f)
        Create a new ZipWith specialized for 5 inputs.

        Parameters:
        f - zipping-function from the input values to the output value
        attributes - optional attributes for this vertex
      • create6

        public static <T1,​T2,​T3,​T4,​T5,​T6,​Out> Graph<FanInShape6<T1,​T2,​T3,​T4,​T5,​T6,​Out>,​NotUsed> create6​(Function6<T1,​T2,​T3,​T4,​T5,​T6,​Out> f)
        Create a new ZipWith specialized for 6 inputs.

        Parameters:
        f - zipping-function from the input values to the output value
        attributes - optional attributes for this vertex
      • create7

        public static <T1,​T2,​T3,​T4,​T5,​T6,​T7,​Out> Graph<FanInShape7<T1,​T2,​T3,​T4,​T5,​T6,​T7,​Out>,​NotUsed> create7​(Function7<T1,​T2,​T3,​T4,​T5,​T6,​T7,​Out> f)
        Create a new ZipWith specialized for 7 inputs.

        Parameters:
        f - zipping-function from the input values to the output value
        attributes - optional attributes for this vertex
      • create8

        public static <T1,​T2,​T3,​T4,​T5,​T6,​T7,​T8,​Out> Graph<FanInShape8<T1,​T2,​T3,​T4,​T5,​T6,​T7,​T8,​Out>,​NotUsed> create8​(Function8<T1,​T2,​T3,​T4,​T5,​T6,​T7,​T8,​Out> f)
        Create a new ZipWith specialized for 8 inputs.

        Parameters:
        f - zipping-function from the input values to the output value
        attributes - optional attributes for this vertex
      • create9

        public static <T1,​T2,​T3,​T4,​T5,​T6,​T7,​T8,​T9,​Out> Graph<FanInShape9<T1,​T2,​T3,​T4,​T5,​T6,​T7,​T8,​T9,​Out>,​NotUsed> create9​(Function9<T1,​T2,​T3,​T4,​T5,​T6,​T7,​T8,​T9,​Out> f)
        Create a new ZipWith specialized for 9 inputs.

        Parameters:
        f - zipping-function from the input values to the output value
        attributes - optional attributes for this vertex
      • create10

        public static <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 new ZipWith specialized for 10 inputs.

        Parameters:
        f - zipping-function from the input values to the output value
        attributes - optional attributes for this vertex
      • create11

        public static <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 new ZipWith specialized for 11 inputs.

        Parameters:
        f - zipping-function from the input values to the output value
        attributes - optional attributes for this vertex
      • create12

        public static <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 new ZipWith specialized for 12 inputs.

        Parameters:
        f - zipping-function from the input values to the output value
        attributes - optional attributes for this vertex
      • create13

        public static <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 new ZipWith specialized for 13 inputs.

        Parameters:
        f - zipping-function from the input values to the output value
        attributes - optional attributes for this vertex
      • create14

        public static <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 new ZipWith specialized for 14 inputs.

        Parameters:
        f - zipping-function from the input values to the output value
        attributes - optional attributes for this vertex
      • create15

        public static <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 new ZipWith specialized for 15 inputs.

        Parameters:
        f - zipping-function from the input values to the output value
        attributes - optional attributes for this vertex
      • create16

        public static <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 new ZipWith specialized for 16 inputs.

        Parameters:
        f - zipping-function from the input values to the output value
        attributes - optional attributes for this vertex
      • create17

        public static <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 new ZipWith specialized for 17 inputs.

        Parameters:
        f - zipping-function from the input values to the output value
        attributes - optional attributes for this vertex
      • create18

        public static <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 new ZipWith specialized for 18 inputs.

        Parameters:
        f - zipping-function from the input values to the output value
        attributes - optional attributes for this vertex
      • create19

        public static <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 new ZipWith specialized for 19 inputs.

        Parameters:
        f - zipping-function from the input values to the output value
        attributes - optional attributes for this vertex
      • create20

        public static <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 new ZipWith specialized for 20 inputs.

        Parameters:
        f - zipping-function from the input values to the output value
        attributes - optional attributes for this vertex
      • create21

        public static <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 new ZipWith specialized for 21 inputs.

        Parameters:
        f - zipping-function from the input values to the output value
        attributes - optional attributes for this vertex
      • create22

        public static <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 new ZipWith specialized for 22 inputs.

        Parameters:
        f - zipping-function from the input values to the output value
        attributes - optional attributes for this vertex