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

Adheres to the ActorAttributes.SupervisionStrategy attribute.

If the combiner function throws and the supervision decision is pekko.stream.Supervision.Stop the stream fails. If the supervision decision is pekko.stream.Supervision.Resume or pekko.stream.Supervision.Restart the zipped element is dropped and the stream continues.

  • 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)