Class KeepAliveConcat<T>

Sends elements from buffer if upstream does not emit for a configured amount of time. In other words, this stage attempts to maintains a base rate of emitted elements towards the downstream using elements from upstream.

If upstream emits new elements until the accumulated elements in the buffer exceed the specified minimum size used as the keep alive elements, then the base rate is no longer maintained until we reach another period without elements form upstream.

The keep alive period is the keep alive failover size times the interval.

Emits when upstream emits an element or if the upstream was idle for the configured period

Backpressures when downstream backpressures

Completes when upstream completes

Cancels when downstream cancels

Inheritance
Object
GraphStageWithMaterializedValue<FlowShape<T, T>, NotUsed>
GraphStage<FlowShape<T, T>>
KeepAliveConcat<T>
Implements
Inherited Members
Namespace: Akka.Streams.Dsl
Assembly: Akka.Streams.dll
Syntax
public class KeepAliveConcat<T> : GraphStage<FlowShape<T, T>>, IGraphStageWithMaterializedValue<FlowShape<T, T>, NotUsed>, IGraph<FlowShape<T, T>, NotUsed>, IGraph<FlowShape<T, T>>
Type Parameters
Name Description
T

type of element

Constructors

| Improve this Doc View Source

KeepAliveConcat(Int32, TimeSpan, Func<T, IEnumerable<T>>)

Declaration
public KeepAliveConcat(int keepAliveFailoverSize, TimeSpan interval, Func<T, IEnumerable<T>> extrapolate)
Parameters
Type Name Description
Int32 keepAliveFailoverSize
TimeSpan interval
Func<T, IEnumerable<T>> extrapolate

Properties

| Improve this Doc View Source

In

Declaration
public Inlet<T> In { get; }
Property Value
Type Description
Inlet<T>
| Improve this Doc View Source

Out

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

Shape

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

Methods

| Improve this Doc View Source

CreateLogic(Attributes)

Declaration
protected override GraphStageLogic CreateLogic(Attributes inheritedAttributes)
Parameters
Type Name Description
Attributes inheritedAttributes
Returns
Type Description
GraphStageLogic
Overrides
Akka.Streams.Stage.GraphStage<Akka.Streams.FlowShape<T, T>>.CreateLogic(Akka.Streams.Attributes)

Implements

Extension Methods