Class MergeSorted<T>

  • All Implemented Interfaces:
    Graph<FanInShape2<T,​T,​T>,​NotUsed>

    public final class MergeSorted<T>
    extends GraphStage<FanInShape2<T,​T,​T>>
    Merge two pre-sorted streams such that the resulting stream is sorted.

    '''Emits when''' both inputs have an element available

    '''Backpressures when''' downstream backpressures

    '''Completes when''' all upstreams complete

    '''Cancels when''' downstream cancels