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 backpressures
Completes when all upstreams complete
Cancels when downstream cancels
Implements
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
| Edit this page View SourceMergeSorted(Func<T, T, int>)
Initializes a new instance of the MergeSorted<T> class.
Declaration
public MergeSorted(Func<T, T, int> compare)Parameters
| Type | Name | Description |
|---|---|---|
| Func<T, T, int> | compare | TBD |
Fields
| Edit this page View SourceLeft
TBD
Declaration
public readonly Inlet<T> LeftField Value
| Type | Description |
|---|---|
| Inlet<T> |
Out
TBD
Declaration
public readonly Outlet<T> OutField Value
| Type | Description |
|---|---|
| Outlet<T> |
Right
TBD
Declaration
public readonly Inlet<T> RightField Value
| Type | Description |
|---|---|
| Inlet<T> |
Properties
| Edit this page View SourceShape
TBD
Declaration
public override FanInShape<T, T, T> Shape { get; }Property Value
| Type | Description |
|---|---|
| FanInShape<T, T, T> |
Overrides
Methods
| Edit this page View SourceCreateLogic(Attributes)
TBD
Declaration
protected override GraphStageLogic CreateLogic(Attributes inheritedAttributes)Parameters
| Type | Name | Description |
|---|---|---|
| Attributes | inheritedAttributes | TBD |
Returns
| Type | Description |
|---|---|
| GraphStageLogic | TBD |
Edit this page