Package org.apache.pekko.stream.scaladsl

Class MergeSorted<T>

java.lang.Object

org.apache.pekko.stream.stage.GraphStageWithMaterializedValue<S,NotUsed>

org.apache.pekko.stream.stage.GraphStage<FanInShape2<T,T,T>>

org.apache.pekko.stream.scaladsl.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

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.pekko.stream.Graph

Graph.GraphMapMatVal<S extends Shape,M>

Constructor Summary

Constructors

Constructor	Description
MergeSorted(scala.math.Ordering<T> evidence$2)

Method Summary

Modifier and Type	Method	Description
static <T> MergeSorted<T>	apply(scala.math.Ordering<T> evidence$1)	Create a new MergeSorted, @see MergeSorted
GraphStageLogic	createLogic(Attributes attr)
FanInShape2<T,T,T>	shape()	The shape of a graph is all that is externally visible: its inlets and outlets.

Methods inherited from class org.apache.pekko.stream.stage.GraphStage

createLogicAndMaterializedValue

Methods inherited from class org.apache.pekko.stream.stage.GraphStageWithMaterializedValue

initialAttributes, withAttributes

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.pekko.stream.Graph

addAttributes, async, async, async, getAttributes, named

Constructor Details

MergeSorted

public MergeSorted(scala.math.Ordering<T> evidence$2)

Method Details

apply

public static <T> MergeSorted<T> apply(scala.math.Ordering<T> evidence$1)

Create a new MergeSorted, @see MergeSorted

shape

public FanInShape2<T,T,T> shape()

Description copied from interface: Graph

The shape of a graph is all that is externally visible: its inlets and outlets.

createLogic

public GraphStageLogic createLogic(Attributes attr)

Specified by:

createLogic in class GraphStage<FanInShape2<T,T,T>>