Package org.apache.pekko.stream.javadsl

Class ZipLatest

  • public class ZipLatest
extends java.lang.Object
    Combine the elements of 2 streams into a stream of tuples, picking always the latest element of each.

    A Zip has a left and a right input port and one out port

    '''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 upstream completes

    '''Cancels when''' downstream cancels

    • Constructor Summary

      Constructors 
      Constructor Description
      ZipLatest()  

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static <A,​B>
      Graph<FanInShape2<A,​B,​Pair<A,​B>>,​NotUsed>      		 create()
      Create a new ZipLatest operator with the specified input types and zipping-function which creates org.apache.pekko.japi.Pairs.

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • ZipLatest

        public ZipLatest()

    • Method Detail

      • create

        public static <A,​B> Graph<FanInShape2<A,​B,​Pair<A,​B>>,​NotUsed> create()
        Create a new ZipLatest operator with the specified input types and zipping-function which creates org.apache.pekko.japi.Pairs.