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

IGraphStageWithMaterializedValue<UniformFanInShape<T, T>, NotUsed>

IGraph<UniformFanInShape<T, T>, NotUsed>

IGraph<UniformFanInShape<T, T>>

Inherited Members

Merge<T, T>.In(int)

Merge<T, T>.Out

Merge<T, T>.Shape

Merge<T, T>.ToString()

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

Merge(int, bool)

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

Declaration

public Merge(int inputPorts, bool eagerComplete = false)

Parameters

Type	Name	Description
int	inputPorts	TBD
bool	eagerComplete	TBD

Implements

IGraphStageWithMaterializedValue<TShape, TMaterialized>

IGraph<TShape, TMaterialized>

IGraph<TShape>

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(object)