Package akka.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

    • Field Summary

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

    • Constructor Summary

      Constructors 
      Constructor Description
      ZipLatest$()  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      <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 akka.japi.Pairs.

      • Methods inherited from class java.lang.Object

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

    • Field Detail

      • MODULE$

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

    • Constructor Detail

      • ZipLatest$

        public ZipLatest$()

    • Method Detail

      • create

        public <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 akka.japi.Pairs.