Class Pulse<T>

Pulse stage signals demand only once every "pulse" interval and then back-pressures. Requested element is emitted downstream if there is demand. It can be used to implement simple time-window processing where data is aggregated for predefined amount of time and the computed aggregate is emitted once per this time.

Inheritance

object

GraphStageWithMaterializedValue<FlowShape<T, T>, NotUsed>

GraphStage<FlowShape<T, T>>

SimpleLinearGraphStage<T>

Pulse<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 Pulse<T> : SimpleLinearGraphStage<T>, IGraphStageWithMaterializedValue<FlowShape<T, T>, NotUsed>, IGraph<FlowShape<T, T>, NotUsed>, IGraph<FlowShape<T, T>>

Type Parameters

Name	Description
T	type of element

Constructors

Pulse(TimeSpan, bool)

Declaration

public Pulse(TimeSpan interval, bool initiallyOpen = false)

Parameters

Type	Name	Description
TimeSpan	interval	"pulse" period
bool	initiallyOpen	if true - emits the first available element before "pulsing"

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)