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

    • Constructor Summary

      Constructors 
      Constructor Description
      Zip()  

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

    • Constructor Detail

      • Zip

        public Zip()

    • Method Detail

      • create

        public static <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.