Package org.apache.pekko.stream.javadsl
Class MergeSorted$
- java.lang.Object
-
- org.apache.pekko.stream.javadsl.MergeSorted$
-
public class MergeSorted$ extends java.lang.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 MergeSorted$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description MergeSorted$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <T extends java.lang.Comparable<T>>
Graph<FanInShape2<T,T,T>,NotUsed>create()
Create a newMergeSorted
operator with the specified input type.<T> Graph<FanInShape2<T,T,T>,NotUsed>
create(java.util.Comparator<T> comparator)
Create a newMergeSorted
operator with the specified input type.
-
-
-
Field Detail
-
MODULE$
public static final MergeSorted$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
create
public <T extends java.lang.Comparable<T>> Graph<FanInShape2<T,T,T>,NotUsed> create()
Create a newMergeSorted
operator with the specified input type.
-
create
public <T> Graph<FanInShape2<T,T,T>,NotUsed> create(java.util.Comparator<T> comparator)
Create a newMergeSorted
operator with the specified input type.
-
-