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

IGraphStageWithMaterializedValue<FlowShape<T, T>, NotUsed>

IGraph<FlowShape<T, T>, NotUsed>

IGraph<FlowShape<T, T>>

Inherited Members

GraphStage<FlowShape<T, T>>.CreateLogicAndMaterializedValue(Attributes)

GraphStage<FlowShape<T, T>>.CreateLogic(Attributes)

GraphStageWithMaterializedValue<FlowShape<T, T>, NotUsed>.InitialAttributes

GraphStageWithMaterializedValue<FlowShape<T, T>, NotUsed>.Shape

GraphStageWithMaterializedValue<FlowShape<T, T>, NotUsed>.WithAttributes(Attributes)

GraphStageWithMaterializedValue<FlowShape<T, T>, NotUsed>.CreateLogicAndMaterializedValue(Attributes)

GraphStageWithMaterializedValue<FlowShape<T, T>, NotUsed>.Module

GraphStageWithMaterializedValue<FlowShape<T, T>, NotUsed>.AddAttributes(Attributes)

GraphStageWithMaterializedValue<FlowShape<T, T>, NotUsed>.Named(string)

GraphStageWithMaterializedValue<FlowShape<T, T>, 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 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

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

Declaration

public KeepAliveConcat(int keepAliveFailoverSize, TimeSpan interval, Func<T, IEnumerable<T>> extrapolate)

Parameters

Type	Name	Description
int	keepAliveFailoverSize
TimeSpan	interval
Func<T, IEnumerable<T>>	extrapolate

Properties

In

Declaration

public Inlet<T> In { get; }

Property Value

Type	Description
Inlet<T>

Out

Declaration

public Outlet<T> Out { get; }

Property Value

Type	Description
Outlet<T>

Shape

TBD

Declaration

public override FlowShape<T, T> Shape { get; }

Property Value

Type	Description
FlowShape<T, T>

Overrides

GraphStageWithMaterializedValue<FlowShape<T, T>, 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<FlowShape<T, T>>.CreateLogic(Attributes)

Implements

IGraphStageWithMaterializedValue<TShape, TMaterialized>

IGraph<TShape, TMaterialized>

IGraph<TShape>

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(object)