Class Interleave<TIn, TOut>

Interleave represents deterministic merge which takes N elements per input stream, in-order of inputs, emits them downstream and then cycles/"wraps-around" the inputs.

Emits when element is available from current input (depending on phase)

Backpressures when downstream backpressures

Completes when all upstreams complete (eagerComplete=false) or one upstream completes (eagerComplete=true)

Cancels when downstream cancels
Inheritance
object
GraphStageWithMaterializedValue<UniformFanInShape<TIn, TOut>, NotUsed>
GraphStage<UniformFanInShape<TIn, TOut>>
Interleave<TIn, TOut>
Implements
Inherited Members
Namespace: Akka.Streams.Dsl
Assembly: Akka.Streams.dll
Syntax
public sealed class Interleave<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

Properties

| 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