Package org.apache.pekko.stream.javadsl

Class Unzip

  • public class Unzip
extends java.lang.Object
    Takes a stream of pair elements and splits each pair to two output streams.

    An Unzip has one in port and one left and one right output port.

    '''Emits when''' all of the outputs stops backpressuring and there is an input element available

    '''Backpressures when''' any of the outputs backpressures

    '''Completes when''' upstream completes

    '''Cancels when''' any downstream cancels

    • Constructor Summary

      Constructors 
      Constructor Description
      Unzip()  

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static <A,​B>
      Graph<FanOutShape2<Pair<A,​B>,​A,​B>,​NotUsed>      		 create()
      Creates a new Unzip operator with the specified output types.
      static <A,​B>
      Graph<FanOutShape2<Pair<A,​B>,​A,​B>,​NotUsed>      		 create​(java.lang.Class<A> left, java.lang.Class<B> right)
      Creates a new Unzip operator with the specified output types.

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • Unzip

        public Unzip()

    • Method Detail

      • create

        public static <A,​B> Graph<FanOutShape2<Pair<A,​B>,​A,​B>,​NotUsed> create()
        Creates a new Unzip operator with the specified output types.

      • create

        public static <A,​B> Graph<FanOutShape2<Pair<A,​B>,​A,​B>,​NotUsed> create​(java.lang.Class<A> left,
                                                                                                    java.lang.Class<B> right)
        Creates a new Unzip operator with the specified output types.