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

    • Field Summary

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

      Constructors 
      Constructor Description
      Unzip$()  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      <A,​B>
      Unzip<A,​B>
      apply()
      Create a new Unzip.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Field Detail

      • MODULE$

        public static final Unzip$ MODULE$
        Static reference to the singleton instance of this Scala object.
    • Constructor Detail

      • Unzip$

        public Unzip$()
    • Method Detail

      • apply

        public <A,​B> Unzip<A,​B> apply()
        Create a new Unzip.