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>>
Akka.Streams.Implementation.Fusing.SimpleLinearGraphStage<T>
Pulse<T>
Implements
Inherited Members
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

| Improve this Doc View Source

Pulse(TimeSpan, Boolean)

Declaration
public Pulse(TimeSpan interval, bool initiallyOpen = false)
Parameters
Type Name Description
TimeSpan interval

"pulse" period
Boolean initiallyOpen

if 

true
- emits the first available element before "pulsing"

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