Class ZipWithN<A,​O>

  • All Implemented Interfaces:
    Graph<UniformFanInShape<A,​O>,​NotUsed>
    Direct Known Subclasses:
    ZipN

    public class ZipWithN<A,​O>
    extends GraphStage<UniformFanInShape<A,​O>>
    Combine the elements of multiple streams into a stream of sequences using a combiner function.

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

      • ZipWithN

        public ZipWithN​(scala.Function1<scala.collection.immutable.Seq<A>,​O> zipper,
                        int n)