Class Unzip<A,​B>

  • All Implemented Interfaces:
    Graph<FanOutShape2<scala.Tuple2<A,​B>,​A,​B>,​NotUsed>

    public final class Unzip<A,​B>
    extends UnzipWith2<scala.Tuple2<A,​B>,​A,​B>
    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 stop backpressuring and there is an input element available

    '''Backpressures when''' any of the outputs backpressure

    '''Completes when''' upstream completes

    '''Cancels when''' any downstream cancels

    • Constructor Detail

      • Unzip

        public Unzip()
    • Method Detail

      • apply

        public static <A,​B> Unzip<A,​B> apply()
        Create a new Unzip.
        Returns:
        (undocumented)
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class UnzipWith2<scala.Tuple2<A,​B>,​A,​B>