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
Inherited Members
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

| Improve this Doc View Source

MergePrioritized(IEnumerable<Int32>, Boolean)

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<Int32> priorities

Priorities of the input ports
Boolean 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

| Improve this Doc View Source

In

Declaration
public IReadOnlyList<Inlet<T>> In { get; }
Property Value
Type Description
IReadOnlyList<Inlet<T>>
| Improve this Doc View Source

InitialAttributes

Declaration
protected override Attributes InitialAttributes { get; }
Property Value
Type Description
Attributes
Overrides
Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.UniformFanInShape<T, T>, Akka.NotUsed>.InitialAttributes
| Improve this Doc View Source

Out

Declaration
public Outlet<T> Out { get; }
Property Value
Type Description
Outlet<T>
| Improve this Doc View Source

Shape

Declaration
public override UniformFanInShape<T, T> Shape { get; }
Property Value
Type Description
UniformFanInShape<T, T>
Overrides
Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.UniformFanInShape<T, T>, Akka.NotUsed>.Shape

Methods

| Improve this Doc View Source

CreateLogic(Attributes)

Declaration
protected override GraphStageLogic CreateLogic(Attributes inheritedAttributes)
Parameters
Type Name Description
Attributes inheritedAttributes
Returns
Type Description
GraphStageLogic
Overrides
Akka.Streams.Stage.GraphStage<Akka.Streams.UniformFanInShape<T, T>>.CreateLogic(Akka.Streams.Attributes)

Implements

Extension Methods