Class ZipWithN

  • public class ZipWithN
    extends java.lang.Object
    Combine the elements of multiple streams into a stream of lists 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 Summary

      Constructor Description