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

| 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
| Improve this Doc View Source

ToString()

TBD

Declaration
public override string ToString()
Returns
Type Description
String

TBD
Overrides

Implements

Extension Methods