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

| Edit this page View Source

ReuseLatest()

Declaration
public ReuseLatest()
| Edit this page View Source

ReuseLatest(Action<T, T>)

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

Properties

| Edit this page View Source

Shape

TBD

Declaration
public override FlowShape<T, T> Shape { get; }
Property Value
Type Description
FlowShape<T, T>
Overrides

Methods

| Edit this page View Source

CreateLogic(Attributes)

TBD

Declaration
protected override GraphStageLogic CreateLogic(Attributes inheritedAttributes)
Parameters
Type Name Description
Attributes inheritedAttributes

TBD
Returns
Type Description
GraphStageLogic

TBD
Overrides
| Edit this page View Source

ToString()

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

Implements

Extension Methods