Class Merge<T>

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<T, T>, NotUsed>
GraphStage<UniformFanInShape<T, T>>
Merge<T, T>
Merge<T>
Implements
Inherited Members
Namespace: Akka.Streams.Dsl
Assembly: Akka.Streams.dll
Syntax
public sealed class Merge<T> : Merge<T, T>, IGraphStageWithMaterializedValue<UniformFanInShape<T, T>, NotUsed>, IGraph<UniformFanInShape<T, T>, NotUsed>, IGraph<UniformFanInShape<T, T>>
Type Parameters
Name Description
T

TBD

Constructors

| Improve this Doc View Source

Merge(Int32, Boolean)

Initializes a new instance of the Merge<T> class.

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

TBD
Boolean eagerComplete

TBD

Implements

Extension Methods