Class Merge<TIn, TOut>

Merge several streams, taking elements as they arrive from input streams (picking randomly when several have elements ready).

Emits when one of the inputs has an element available

Backpressures when downstream backpressures

Completes when all upstreams complete

Cancels when downstream cancels
Inheritance
object
GraphStageWithMaterializedValue<UniformFanInShape<TIn, TOut>, NotUsed>
GraphStage<UniformFanInShape<TIn, TOut>>
Merge<TIn, TOut>
Merge<T>
Implements
Inherited Members
Namespace: Akka.Streams.Dsl
Assembly: Akka.Streams.dll
Syntax
public class Merge<TIn, TOut> : GraphStage<UniformFanInShape<TIn, TOut>>, IGraphStageWithMaterializedValue<UniformFanInShape<TIn, TOut>, NotUsed>, IGraph<UniformFanInShape<TIn, TOut>, NotUsed>, IGraph<UniformFanInShape<TIn, TOut>> where TIn : TOut
Type Parameters
Name Description
TIn

TBD
TOut

TBD

Constructors

| Edit this page View Source

Merge(int, bool)

Initializes a new instance of the Merge<TIn, TOut> class.

Declaration
public Merge(int inputPorts, bool eagerComplete = false)
Parameters
Type Name Description
int inputPorts

TBD
bool eagerComplete

TBD
Exceptions
Type Condition
ArgumentException

This exception is thrown when the specified inputPorts is less than one.

Properties

| Edit this page View Source

InitialAttributes

TBD

Declaration
protected override Attributes InitialAttributes { get; }
Property Value
Type Description
Attributes
Overrides
| Edit this page View Source

Out

TBD

Declaration
public Outlet<TOut> Out { get; }
Property Value
Type Description
Outlet<TOut>
| Edit this page View Source

Shape

TBD

Declaration
public override UniformFanInShape<TIn, TOut> Shape { get; }
Property Value
Type Description
UniformFanInShape<TIn, TOut>
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
| Edit this page View Source

In(int)

TBD

Declaration
public Inlet<TIn> In(int id)
Parameters
Type Name Description
int id

TBD
Returns
Type Description
Inlet<TIn>

TBD
| Edit this page View Source

ToString()

TBD

Declaration
public override string ToString()
Returns
Type Description
string

TBD
Overrides

Implements

Extension Methods