Class ZipN<A>

  • All Implemented Interfaces:
    Graph<UniformFanInShape<A,​scala.collection.immutable.Seq<A>>,​NotUsed>

    public final class ZipN<A>
    extends ZipWithN<A,​scala.collection.immutable.Seq<A>>
    Combine the elements of multiple streams into a stream of sequences.

    A ZipN has a n input ports 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

      • ZipN

        public ZipN​(int n)
    • Method Detail

      • apply

        public static <A> ZipN<A> apply​(int n)
        Create a new ZipN.
        Parameters:
        n - (undocumented)
        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)
      • out

        public static Outlet<O> out()
      • inSeq

        public static scala.collection.immutable.IndexedSeq<Inlet<A>> inSeq()
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class ZipWithN<A,​scala.collection.immutable.Seq<A>>