Class LastElement<T>

This stage materializes to the last element pushed before upstream completion, if any, thereby recovering from any failure. Pushed elements are just passed along.

Inheritance

Object

GraphStageWithMaterializedValue<FlowShape<T, T>, Task<Option<T>>>

LastElement<T>

Implements

IGraphStageWithMaterializedValue<FlowShape<T, T>, Task<Option<T>>>

IGraph<FlowShape<T, T>, Task<Option<T>>>

IGraph<FlowShape<T, T>>

Inherited Members

GraphStageWithMaterializedValue<FlowShape<T, T>, Task<Option<T>>>.InitialAttributes

GraphStageWithMaterializedValue<FlowShape<T, T>, Task<Option<T>>>.Shape

GraphStageWithMaterializedValue<FlowShape<T, T>, Task<Option<T>>>.WithAttributes(Attributes)

GraphStageWithMaterializedValue<FlowShape<T, T>, Task<Option<T>>>.CreateLogicAndMaterializedValue(Attributes)

GraphStageWithMaterializedValue<FlowShape<T, T>, Task<Option<T>>>.Module

GraphStageWithMaterializedValue<FlowShape<T, T>, Task<Option<T>>>.AddAttributes(Attributes)

GraphStageWithMaterializedValue<FlowShape<T, T>, Task<Option<T>>>.Named(String)

GraphStageWithMaterializedValue<FlowShape<T, T>, Task<Option<T>>>.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 LastElement<T> : GraphStageWithMaterializedValue<FlowShape<T, T>, Task<Option<T>>>, IGraphStageWithMaterializedValue<FlowShape<T, T>, Task<Option<T>>>, IGraph<FlowShape<T, T>, Task<Option<T>>>, IGraph<FlowShape<T, T>>

Type Parameters

Name	Description
T	input and output type

Constructors

LastElement()

Declaration

public LastElement()

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

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>, System.Threading.Tasks.Task<Akka.Util.Option<T>>>.Shape

Methods

CreateLogicAndMaterializedValue(Attributes)

Declaration

public override ILogicAndMaterializedValue<Task<Option<T>>> CreateLogicAndMaterializedValue(Attributes inheritedAttributes)

Parameters

Type	Name	Description
Attributes	inheritedAttributes

Returns

Type	Description
ILogicAndMaterializedValue<Task<Option<T>>>

Overrides

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.FlowShape<T, T>, System.Threading.Tasks.Task<Akka.Util.Option<T>>>.CreateLogicAndMaterializedValue(Akka.Streams.Attributes)

Implements

IGraphStageWithMaterializedValue<TShape, TMaterialized>

IGraph<TShape, TMaterialized>

IGraph<TShape>

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(Object)