Class Concat<TIn, TOut>

Takes two streams and outputs one stream formed from the two input streams by first emitting all of the elements from the first stream and then emitting all of the elements from the second stream.

A Concat<TIn, TOut> has one multiple In(int) ports and one Out port.

Emits when the current stream has an element available; if the current input completes, it tries the next one

Backpressures when downstream backpressures

Completes when all upstreams complete

Cancels when downstream cancels

Inheritance

object

GraphStageWithMaterializedValue<UniformFanInShape<TIn, TOut>, NotUsed>

GraphStage<UniformFanInShape<TIn, TOut>>

Concat<TIn, TOut>

Implements

IGraphStageWithMaterializedValue<UniformFanInShape<TIn, TOut>, NotUsed>

IGraph<UniformFanInShape<TIn, TOut>, NotUsed>

IGraph<UniformFanInShape<TIn, TOut>>

Inherited Members

GraphStage<UniformFanInShape<TIn, TOut>>.CreateLogicAndMaterializedValue(Attributes)

GraphStage<UniformFanInShape<TIn, TOut>>.CreateLogic(Attributes)

GraphStageWithMaterializedValue<UniformFanInShape<TIn, TOut>, NotUsed>.InitialAttributes

GraphStageWithMaterializedValue<UniformFanInShape<TIn, TOut>, NotUsed>.Shape

GraphStageWithMaterializedValue<UniformFanInShape<TIn, TOut>, NotUsed>.WithAttributes(Attributes)

GraphStageWithMaterializedValue<UniformFanInShape<TIn, TOut>, NotUsed>.CreateLogicAndMaterializedValue(Attributes)

GraphStageWithMaterializedValue<UniformFanInShape<TIn, TOut>, NotUsed>.Module

GraphStageWithMaterializedValue<UniformFanInShape<TIn, TOut>, NotUsed>.AddAttributes(Attributes)

GraphStageWithMaterializedValue<UniformFanInShape<TIn, TOut>, NotUsed>.Named(string)

GraphStageWithMaterializedValue<UniformFanInShape<TIn, TOut>, NotUsed>.Async()

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Akka.Streams.Dsl

Assembly: Akka.Streams.dll

Syntax

public class Concat<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

Concat(int)

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

Declaration

public Concat(int inputPorts = 2)

Parameters

Type	Name	Description
int	inputPorts	TBD

Exceptions

Type	Condition
ArgumentException	This exception is thrown when the specified inputPorts is less than or equal to one.

Properties

InitialAttributes

TBD

Declaration

protected override Attributes InitialAttributes { get; }

Property Value

Type	Description
Attributes

Overrides

GraphStageWithMaterializedValue<UniformFanInShape<TIn, TOut>, NotUsed>.InitialAttributes

Out

TBD

Declaration

public Outlet<TOut> Out { get; }

Property Value

Type	Description
Outlet<TOut>

Shape

TBD

Declaration

public override UniformFanInShape<TIn, TOut> Shape { get; }

Property Value

Type	Description
UniformFanInShape<TIn, TOut>

Overrides

GraphStageWithMaterializedValue<UniformFanInShape<TIn, TOut>, 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<TIn, TOut>>.CreateLogic(Attributes)

In(int)

TBD

Declaration

public Inlet<TIn> In(int id)

Parameters

Type	Name	Description
int	id	TBD

Returns

Type	Description
Inlet<TIn>	TBD

Implements

IGraphStageWithMaterializedValue<TShape, TMaterialized>

IGraph<TShape, TMaterialized>

IGraph<TShape>

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(object)