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
Inheritance
object
GraphStageWithMaterializedValue<FanInShape<T, T, T>, NotUsed>
GraphStage<FanInShape<T, T, T>>
MergeSorted<T>
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 Source

MergeSorted(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 Source

Left

TBD

Declaration
public readonly Inlet<T> Left
Field Value
Type Description
Inlet<T>
| Edit this page View Source

Out

TBD

Declaration
public readonly Outlet<T> Out
Field Value
Type Description
Outlet<T>
| Edit this page View Source

Right

TBD

Declaration
public readonly Inlet<T> Right
Field Value
Type Description
Inlet<T>

Properties

| Edit this page View Source

Shape

TBD

Declaration
public override FanInShape<T, T, T> Shape { get; }
Property Value
Type Description
FanInShape<T, T, T>
Overrides

Methods

| Edit this page View Source

CreateLogic(Attributes)

TBD

Declaration
protected override GraphStageLogic CreateLogic(Attributes inheritedAttributes)
Parameters
Type Name Description
Attributes inheritedAttributes

TBD
Returns
Type Description
GraphStageLogic

TBD
Overrides

Implements

Extension Methods