Package org.apache.pekko.stream.javadsl

Class ZipLatestWith$

java.lang.Object
org.apache.pekko.stream.javadsl.ZipLatestWith$
public class ZipLatestWith$ extends Object
Combine the elements of multiple streams into a stream of combined elements using a combiner function, picking always the latest of the elements of each source.

No element is emitted until at least one element from each Source becomes available. Whenever a new element appears, the zipping function is invoked with a tuple containing the new element and the other last seen elements.

'''Emits when''' all of the inputs have at least an element available, and then each time an element becomes available on either of the inputs

'''Backpressures when''' downstream backpressures

'''Completes when''' any of the upstreams completes

'''Cancels when''' downstream cancels

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final ZipLatestWith$
    MODULE$
    Static reference to the singleton instance of this Scala object.

  • Constructor Summary

    Constructors
    Constructor
    Description
    ZipLatestWith$()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    <A, B, Out> Graph<FanInShape2<A,B,Out>,NotUsed>
    create(Function2<A,B,Out> f)
    Create a new ZipLatestWith vertex with the specified input types and zipping-function f.
    <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 ZipLatestWith specialized 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 new ZipLatestWith specialized 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 new ZipLatestWith specialized 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 new ZipLatestWith specialized 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 new ZipLatestWith specialized 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 new ZipLatestWith specialized 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 new ZipLatestWith specialized 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 new ZipLatestWith specialized 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 new ZipLatestWith specialized 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 new ZipLatestWith specialized 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 new ZipLatestWith specialized 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 new ZipLatestWith specialized 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 new ZipLatestWith specialized for 22 inputs.
    <T1, T2, T3, Out>
    Graph<FanInShape3<T1,T2,T3,Out>,NotUsed>
    create3(Function3<T1,T2,T3,Out> f)
    Create a new ZipLatestWith specialized for 3 inputs.
    <T1, T2, T3, T4, Out>
    Graph<FanInShape4<T1,T2,T3,T4,Out>,NotUsed>
    create4(Function4<T1,T2,T3,T4,Out> f)
    Create a new ZipLatestWith specialized for 4 inputs.
    <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 ZipLatestWith specialized for 5 inputs.
    <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 ZipLatestWith specialized for 6 inputs.
    <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 ZipLatestWith specialized for 7 inputs.
    <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 ZipLatestWith specialized 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>
    create9(Function9<T1,T2,T3,T4,T5,T6,T7,T8,T9,Out> f)
    Create a new ZipLatestWith specialized for 9 inputs.

    Methods inherited from class java.lang.Object

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

  • Field Details

    • MODULE$

      public static final ZipLatestWith$ MODULE$
      Static reference to the singleton instance of this Scala object.

  • Constructor Details

    • ZipLatestWith$

      public ZipLatestWith$()

  • Method Details

    • create

      public <A, B, Out> Graph<FanInShape2<A,B,Out>,NotUsed> create(Function2<A,B,Out> f)
      Create a new ZipLatestWith 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 <T1, T2, T3, Out> Graph<FanInShape3<T1,T2,T3,Out>,NotUsed> create3(Function3<T1,T2,T3,Out> f)
      Create a new ZipLatestWith specialized for 3 inputs.

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

    • create4

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

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

    • create5

      public <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 ZipLatestWith specialized for 5 inputs.

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

    • create6

      public <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 ZipLatestWith specialized for 6 inputs.

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

    • create7

      public <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 ZipLatestWith specialized for 7 inputs.

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

    • create8

      public <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 ZipLatestWith specialized for 8 inputs.

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

    • create9

      public <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 ZipLatestWith specialized for 9 inputs.

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

    • create10

      public <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 ZipLatestWith specialized for 10 inputs.

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

    • create11

      public <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 ZipLatestWith specialized for 11 inputs.

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

    • create12

      public <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 ZipLatestWith specialized for 12 inputs.

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

    • create13

      public <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 ZipLatestWith specialized for 13 inputs.

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

    • create14

      public <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 ZipLatestWith specialized for 14 inputs.

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

    • create15

      public <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 ZipLatestWith specialized for 15 inputs.

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

    • create16

      public <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 ZipLatestWith specialized for 16 inputs.

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

    • create17

      public <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 ZipLatestWith specialized for 17 inputs.

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

    • create18

      public <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 ZipLatestWith specialized for 18 inputs.

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

    • create19

      public <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 ZipLatestWith specialized for 19 inputs.

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

    • create20

      public <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 ZipLatestWith specialized for 20 inputs.

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

    • create21

      public <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 ZipLatestWith specialized for 21 inputs.

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

    • create22

      public <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 ZipLatestWith specialized for 22 inputs.

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