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

        public static Graph<S,​M> named​(java.lang.String name)
      • async

        public static Graph<S,​M> async()
      • async

        public static Graph<S,​M> async​(java.lang.String dispatcher)
      • async

        public static Graph<S,​M> async​(java.lang.String dispatcher,
                                             int inputBufferSize)
      • addAttributes

        public static Graph<S,​M> addAttributes​(Attributes attr)
      • withAttributes

        public static final Graph<S,​M> withAttributes​(Attributes attr)
      • createLogicAndMaterializedValue

        public static final scala.Tuple2<GraphStageLogic,​NotUsed> createLogicAndMaterializedValue​(Attributes inheritedAttributes)
      • unzipper

        public static scala.Function1<In,​scala.Tuple2<A1,​A2>> unzipper()
      • initialAttributes

        public static Attributes initialAttributes()
      • shape

        public static FanOutShape2<In,​A1,​A2> shape()
      • in

        public static Inlet<In> in()
      • out0

        public static Outlet<A1> out0()
      • out1

        public static Outlet<A2> out1()
      • toString

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