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

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