Class MergePrioritized<T>

Merge several streams, taking elements as they arrive from input streams (picking from prioritized once when several have elements ready). A MergePrioritized<T> has one Out port, one or more input port with their priorities.

Emits when one of the inputs has an element available, preferring a input based on its priority if multiple have elements available

Backpressures when downstream backpressures

Completes when all upstreams complete (eagerComplete=false) or one upstream completes (eagerComplete=true), default value is `false`

Cancels when downstream cancels

Inheritance

object

GraphStageWithMaterializedValue<UniformFanInShape<T, T>, NotUsed>

GraphStage<UniformFanInShape<T, T>>

MergePrioritized<T>

Implements

IGraphStageWithMaterializedValue<UniformFanInShape<T, T>, NotUsed>

IGraph<UniformFanInShape<T, T>, NotUsed>

IGraph<UniformFanInShape<T, T>>

Inherited Members

GraphStage<UniformFanInShape<T, T>>.CreateLogicAndMaterializedValue(Attributes)

GraphStageWithMaterializedValue<UniformFanInShape<T, T>, NotUsed>.Shape

GraphStageWithMaterializedValue<UniformFanInShape<T, T>, NotUsed>.WithAttributes(Attributes)

GraphStageWithMaterializedValue<UniformFanInShape<T, T>, NotUsed>.CreateLogicAndMaterializedValue(Attributes)

GraphStageWithMaterializedValue<UniformFanInShape<T, T>, NotUsed>.Module

GraphStageWithMaterializedValue<UniformFanInShape<T, T>, NotUsed>.AddAttributes(Attributes)

GraphStageWithMaterializedValue<UniformFanInShape<T, T>, NotUsed>.Named(string)

GraphStageWithMaterializedValue<UniformFanInShape<T, T>, NotUsed>.Async()

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Akka.Streams.Dsl

Assembly: Akka.Streams.dll

Syntax

public sealed class MergePrioritized<T> : GraphStage<UniformFanInShape<T, T>>, IGraphStageWithMaterializedValue<UniformFanInShape<T, T>, NotUsed>, IGraph<UniformFanInShape<T, T>, NotUsed>, IGraph<UniformFanInShape<T, T>>

Type Parameters

Name	Description
T

Constructors

MergePrioritized(IEnumerable<int>, bool)

Create a new MergePrioritized<T> with specified number of input ports.

Declaration

public MergePrioritized(IEnumerable<int> priorities, bool eagerComplete = false)

Parameters

Type	Name	Description
IEnumerable<int>	priorities	Priorities of the input ports
bool	eagerComplete	If true, the merge will complete as soon as one of its inputs completes

Exceptions

Type	Condition
ArgumentException	This exception is thrown when the specified priorities is less or equal zero.

Properties

In

Declaration

public IReadOnlyList<Inlet<T>> In { get; }

Property Value

Type	Description
IReadOnlyList<Inlet<T>>

InitialAttributes

TBD

Declaration

protected override Attributes InitialAttributes { get; }

Property Value

Type	Description
Attributes

Overrides

GraphStageWithMaterializedValue<UniformFanInShape<T, T>, NotUsed>.InitialAttributes

Out

Declaration

public Outlet<T> Out { get; }

Property Value

Type	Description
Outlet<T>

Shape

TBD

Declaration

public override UniformFanInShape<T, T> Shape { get; }

Property Value

Type	Description
UniformFanInShape<T, T>

Overrides

GraphStageWithMaterializedValue<UniformFanInShape<T, T>, NotUsed>.Shape

Methods

CreateLogic(Attributes)

TBD

Declaration

protected override GraphStageLogic CreateLogic(Attributes inheritedAttributes)

Parameters

Type	Name	Description
Attributes	inheritedAttributes	TBD

Returns

Type	Description
GraphStageLogic	TBD

Overrides

GraphStage<UniformFanInShape<T, T>>.CreateLogic(Attributes)

Implements

IGraphStageWithMaterializedValue<TShape, TMaterialized>

IGraph<TShape, TMaterialized>

IGraph<TShape>

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(object)