Class ReuseLatest<T>

Reuses the latest element from upstream until it's replaced by a new value.

This is designed to allow fan-in stages where output from one of the sources is intermittent / infrequent and users just want the previous value to be reused.

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

The output type.

Constructors

| Improve this Doc View Source

ReuseLatest()

Declaration
public ReuseLatest()
| Improve this Doc View Source

ReuseLatest(Action<T, T>)

Declaration
public ReuseLatest(Action<T, T> onItemChanged)
Parameters
Type Name Description
Action<T, T> onItemChanged

Properties

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

ToString()

Declaration
public override string ToString()
Returns
Type Description
String
Overrides

Implements

Extension Methods