Class Zip<A,​B>

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

    public final class Zip<A,​B>
    extends ZipWith2<A,​B,​scala.Tuple2<A,​B>>
    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 Detail

      • Zip

        public Zip()
    • Method Detail

      • apply

        public static <A,​B> Zip<A,​B> apply()
        Create a new Zip.
        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)
      • zipper

        public static scala.Function2<A1,​A2,​O> zipper()
      • initialAttributes

        public static Attributes initialAttributes()
      • shape

        public static FanInShape2<A1,​A2,​O> shape()
      • out

        public static Outlet<O> out()
      • in0

        public static Inlet<A1> in0()
      • in1

        public static Inlet<A2> in1()
      • toString

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