public final class MergeSorted<T> extends GraphStage<FanInShape2<T,T,T>>
'''Emits when''' both inputs have an element available
'''Backpressures when''' downstream backpressures
'''Completes when''' all upstreams complete
'''Cancels when''' downstream cancels
Constructor and Description |
---|
MergeSorted(scala.math.Ordering<T> evidence$1) |
Modifier and Type | Method and Description |
---|---|
GraphStageLogic |
createLogic(Attributes attr) |
FanInShape2<T,T,T> |
shape()
The shape of a graph is all that is externally visible: its inlets and outlets.
|
createLogicAndMaterializedValue
initialAttributes, module, withAttributes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addAttributes, async, named
public MergeSorted(scala.math.Ordering<T> evidence$1)
public FanInShape2<T,T,T> shape()
Graph
public GraphStageLogic createLogic(Attributes attr)
createLogic
in class GraphStage<FanInShape2<T,T,T>>