MergeSorted

java.lang.Object

org.apache.pekko.stream.javadsl.MergeSorted

public class MergeSorted extends Object

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

Constructor Summary

Constructors

Constructor

Description

MergeSorted()
Method Summary

Modifier and Type

Method

Description

static <T extends Comparable<T>> Graph<FanInShape2<T,T,T>,NotUsed>

create()

Create a new MergeSorted operator with the specified input type.

static <T> Graph<FanInShape2<T,T,T>,NotUsed>

create(Comparator<T> comparator)

Create a new MergeSorted operator with the specified input type.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- MergeSorted
  
  public MergeSorted()
Method Details
- create
  
  public static <T extends Comparable<T>> Graph<FanInShape2<T,T,T>,NotUsed> create()
  
  Create a new MergeSorted operator with the specified input type.
- create
  
  public static <T> Graph<FanInShape2<T,T,T>,NotUsed> create(Comparator<T> comparator)
  
  Create a new MergeSorted operator with the specified input type.