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(Int32) 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
Inherited Members
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

| Improve this Doc View Source

Concat(Int32)

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

Declaration
public Concat(int inputPorts = 2)
Parameters
Type Name Description
Int32 inputPorts

TBD
Exceptions
Type Condition
ArgumentException

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

Properties

| Improve this Doc View Source

InitialAttributes

TBD

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

Out

TBD

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

Shape

TBD

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

Methods

| Improve this Doc 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
Akka.Streams.Stage.GraphStage<Akka.Streams.UniformFanInShape<TIn, TOut>>.CreateLogic(Akka.Streams.Attributes)
| Improve this Doc View Source

In(Int32)

TBD

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

TBD
Returns
Type Description
Inlet<TIn>

TBD

Implements

Extension Methods