Package org.apache.pekko.stream.scaladsl

Class ZipWith

java.lang.Object
org.apache.pekko.stream.scaladsl.ZipWith
public class ZipWith extends 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

    Modifier and Type
    Method
    Description
    static <A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, O>
    ZipWith10<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,O>
    apply(scala.Function10<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,O> zipper)
     
    static <A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, O>
    ZipWith11<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,O>
    apply(scala.Function11<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,O> zipper)
     
    static <A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, O>
    ZipWith12<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,O>
    apply(scala.Function12<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,O> zipper)
     
    static <A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, O>
    ZipWith13<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,O>
    apply(scala.Function13<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,O> zipper)
     
    static <A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, O>
    ZipWith14<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,O>
    apply(scala.Function14<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,O> zipper)
     
    static <A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, O>
    ZipWith15<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,O>
    apply(scala.Function15<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,O> zipper)
     
    static <A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, O>
    ZipWith16<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,O>
    apply(scala.Function16<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,O> zipper)
     
    static <A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, O>
    ZipWith17<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,O>
    apply(scala.Function17<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,O> zipper)
     
    static <A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, O>
    ZipWith18<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,O>
    apply(scala.Function18<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,O> zipper)
     
    static <A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, O>
    ZipWith19<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,O>
    apply(scala.Function19<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,O> zipper)
     
    static <A1, A2, O> ZipWith2<A1,A2,O>
    apply(scala.Function2<A1,A2,O> zipper)
     
    static <A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, O>
    ZipWith20<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,O>
    apply(scala.Function20<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,O> zipper)
     
    static <A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21, O>
    ZipWith21<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,A21,O>
    apply(scala.Function21<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,A21,O> zipper)
     
    static <A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21, A22, O>
    ZipWith22<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,A21,A22,O>
    apply(scala.Function22<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,A21,A22,O> zipper)
     
    static <A1, A2, A3, O>
    ZipWith3<A1,A2,A3,O>
    apply(scala.Function3<A1,A2,A3,O> zipper)
     
    static <A1, A2, A3, A4, O>
    ZipWith4<A1,A2,A3,A4,O>
    apply(scala.Function4<A1,A2,A3,A4,O> zipper)
     
    static <A1, A2, A3, A4, A5, O>
    ZipWith5<A1,A2,A3,A4,A5,O>
    apply(scala.Function5<A1,A2,A3,A4,A5,O> zipper)
     
    static <A1, A2, A3, A4, A5, A6, O>
    ZipWith6<A1,A2,A3,A4,A5,A6,O>
    apply(scala.Function6<A1,A2,A3,A4,A5,A6,O> zipper)
     
    static <A1, A2, A3, A4, A5, A6, A7, O>
    ZipWith7<A1,A2,A3,A4,A5,A6,A7,O>
    apply(scala.Function7<A1,A2,A3,A4,A5,A6,A7,O> zipper)
     
    static <A1, A2, A3, A4, A5, A6, A7, A8, O>
    ZipWith8<A1,A2,A3,A4,A5,A6,A7,A8,O>
    apply(scala.Function8<A1,A2,A3,A4,A5,A6,A7,A8,O> zipper)
     
    static <A1, A2, A3, A4, A5, A6, A7, A8, A9, O>
    ZipWith9<A1,A2,A3,A4,A5,A6,A7,A8,A9,O>
    apply(scala.Function9<A1,A2,A3,A4,A5,A6,A7,A8,A9,O> zipper)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • ZipWith

      public ZipWith()

  • Method Details

    • apply

      public static <A1, A2, O> ZipWith2<A1,A2,O> apply(scala.Function2<A1,A2,O> zipper)

    • apply

      public static <A1, A2, A3, O> ZipWith3<A1,A2,A3,O> apply(scala.Function3<A1,A2,A3,O> zipper)

    • apply

      public static <A1, A2, A3, A4, O> ZipWith4<A1,A2,A3,A4,O> apply(scala.Function4<A1,A2,A3,A4,O> zipper)

    • apply

      public static <A1, A2, A3, A4, A5, O> ZipWith5<A1,A2,A3,A4,A5,O> apply(scala.Function5<A1,A2,A3,A4,A5,O> zipper)

    • apply

      public static <A1, A2, A3, A4, A5, A6, O> ZipWith6<A1,A2,A3,A4,A5,A6,O> apply(scala.Function6<A1,A2,A3,A4,A5,A6,O> zipper)

    • apply

      public static <A1, A2, A3, A4, A5, A6, A7, O> ZipWith7<A1,A2,A3,A4,A5,A6,A7,O> apply(scala.Function7<A1,A2,A3,A4,A5,A6,A7,O> zipper)

    • apply

      public static <A1, A2, A3, A4, A5, A6, A7, A8, O> ZipWith8<A1,A2,A3,A4,A5,A6,A7,A8,O> apply(scala.Function8<A1,A2,A3,A4,A5,A6,A7,A8,O> zipper)

    • apply

      public static <A1, A2, A3, A4, A5, A6, A7, A8, A9, O> ZipWith9<A1,A2,A3,A4,A5,A6,A7,A8,A9,O> apply(scala.Function9<A1,A2,A3,A4,A5,A6,A7,A8,A9,O> zipper)

    • apply

      public static <A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, O> ZipWith10<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,O> apply(scala.Function10<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,O> zipper)

    • apply

      public static <A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, O> ZipWith11<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,O> apply(scala.Function11<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,O> zipper)

    • apply

      public static <A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, O> ZipWith12<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,O> apply(scala.Function12<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,O> zipper)

    • apply

      public static <A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, O> ZipWith13<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,O> apply(scala.Function13<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,O> zipper)

    • apply

      public static <A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, O> ZipWith14<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,O> apply(scala.Function14<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,O> zipper)

    • apply

      public static <A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, O> ZipWith15<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,O> apply(scala.Function15<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,O> zipper)

    • apply

      public static <A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, O> ZipWith16<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,O> apply(scala.Function16<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,O> zipper)

    • apply

      public static <A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, O> ZipWith17<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,O> apply(scala.Function17<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,O> zipper)

    • apply

      public static <A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, O> ZipWith18<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,O> apply(scala.Function18<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,O> zipper)

    • apply

      public static <A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, O> ZipWith19<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,O> apply(scala.Function19<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,O> zipper)

    • apply

      public static <A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, O> ZipWith20<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,O> apply(scala.Function20<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,O> zipper)

    • apply

      public static <A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21, O> ZipWith21<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,A21,O> apply(scala.Function21<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,A21,O> zipper)

    • apply

      public static <A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21, A22, O> ZipWith22<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,A21,A22,O> apply(scala.Function22<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,A21,A22,O> zipper)