Package org.apache.pekko.stream.javadsl

Class 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

Field Summary

Fields

Modifier and Type	Field	Description
static final MergeSorted$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
MergeSorted$()

Method Summary

Modifier and Type	Method	Description
<T extends Comparable<T>> Graph<FanInShape2<T,T,T>,NotUsed>	create()	Create a new MergeSorted operator with the specified input type.
<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

Field Details

MODULE$

public static final MergeSorted$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

MergeSorted$

public MergeSorted$()

Method Details

create

public <T extends Comparable<T>>
Graph<FanInShape2<T,T,T>,NotUsed> create()

Create a new MergeSorted operator with the specified input type.

create

public <T> Graph<FanInShape2<T,T,T>,NotUsed> create(Comparator<T> comparator)

Create a new MergeSorted operator with the specified input type.