Class Merge<T>

  • All Implemented Interfaces:

    public final class Merge<T>
    extends GraphStage<UniformFanInShape<T,​T>>
    Merge several streams, taking elements as they arrive from input streams (picking randomly when several have elements ready).

    '''Emits when''' one of the inputs has an element available

    '''Backpressures when''' downstream backpressures

    '''Completes when''' all upstreams complete (eagerComplete=false) or one upstream completes (eagerComplete=true), default value is false

    '''Cancels when''' downstream cancels

    • Constructor Detail

      • Merge

        public Merge​(int inputPorts,
                     boolean eagerComplete)