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
-
-
Constructor Summary
Constructors Constructor Description MergeSorted()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <T extends java.lang.Comparable<T>>
Graph<FanInShape2<T,T,T>,NotUsed>create()
Create a newMergeSorted
operator with the specified input type.static <T> Graph<FanInShape2<T,T,T>,NotUsed>
create(java.util.Comparator<T> comparator)
Create a newMergeSorted
operator with the specified input type.
-
-
-
Method Detail
-
create
public static <T extends java.lang.Comparable<T>> Graph<FanInShape2<T,T,T>,NotUsed> create()
Create a newMergeSorted
operator with the specified input type.
-
create
public static <T> Graph<FanInShape2<T,T,T>,NotUsed> create(java.util.Comparator<T> comparator)
Create a newMergeSorted
operator with the specified input type.
-
-