Class MergeSorted<T>
Merge two pre-sorted streams such that the resulting stream is sorted.
Emits when both inputs have an element available
Backpressures when downstream backpressuresCompletes when all upstreams complete
Cancels when downstream cancelsImplements
IGraph<FanInShape<T, T, T>>
Inherited Members
Namespace: Akka.Streams.Dsl
Assembly: Akka.Streams.dll
Syntax
public sealed class MergeSorted<T> : GraphStage<FanInShape<T, T, T>>, IGraphStageWithMaterializedValue<FanInShape<T, T, T>, NotUsed>, IGraph<FanInShape<T, T, T>, NotUsed>, IGraph<FanInShape<T, T, T>>
Type Parameters
Name | Description |
---|---|
T | TBD |
Constructors
| Improve this Doc View SourceMergeSorted(Func<T, T, Int32>)
Initializes a new instance of the MergeSorted<T> class.
Declaration
public MergeSorted(Func<T, T, int> compare)
Parameters
Type | Name | Description |
---|---|---|
Func<T, T, Int32> | compare | TBD |
Fields
| Improve this Doc View SourceLeft
TBD
Declaration
public readonly Inlet<T> Left
Field Value
Type | Description |
---|---|
Inlet<T> |
Out
TBD
Declaration
public readonly Outlet<T> Out
Field Value
Type | Description |
---|---|
Outlet<T> |
Right
TBD
Declaration
public readonly Inlet<T> Right
Field Value
Type | Description |
---|---|
Inlet<T> |
Properties
| Improve this Doc View SourceShape
TBD
Declaration
public override FanInShape<T, T, T> Shape { get; }
Property Value
Type | Description |
---|---|
FanInShape<T, T, T> |
Overrides
Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.FanInShape<T, T, T>, Akka.NotUsed>.Shape
Methods
| Improve this Doc View SourceCreateLogic(Attributes)
TBD
Declaration
protected override GraphStageLogic CreateLogic(Attributes inheritedAttributes)
Parameters
Type | Name | Description |
---|---|---|
Attributes | inheritedAttributes | TBD |
Returns
Type | Description |
---|---|
GraphStageLogic | TBD |
Overrides
Akka.Streams.Stage.GraphStage<Akka.Streams.FanInShape<T, T, T>>.CreateLogic(Akka.Streams.Attributes)