Package akka.stream.javadsl

Class Zip$

  • public class Zip$
extends java.lang.Object
    Combine the elements of 2 streams into a stream of tuples.

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

    '''Emits when''' all of the inputs has an element available

    '''Backpressures when''' downstream backpressures

    '''Completes when''' any upstream completes

    '''Cancels when''' downstream cancels

    • Field Summary

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

    • Constructor Summary

      Constructors 
      Constructor Description
      Zip$()  

    • 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 Zip 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 Zip$ MODULE$
        Static reference to the singleton instance of this Scala object.

    • Constructor Detail

      • Zip$

        public Zip$()

    • Method Detail

      • create

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