Class SelectError<T>

INTERNAL API

Maps error with the provided function if it is defined for an error or, otherwise, passes it on unchanged.

While similar to Recover<T> this stage can be used to transform an error signal to a different one without logging it as an error in the process. So in that sense it is NOT exactly equivalent to Recover(e => throw e2) since Recover would log the e2 error.

Inheritance
System.Object
GraphStageWithMaterializedValue<FlowShape<T, T>, NotUsed>
GraphStage<FlowShape<T, T>>
SimpleLinearGraphStage<T>
SelectError<T>
Inherited Members
System.Object.ToString()
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
Namespace: Akka.Streams.Implementation.Fusing
Assembly: Akka.Streams.dll
Syntax
public sealed class SelectError<T> : SimpleLinearGraphStage<T>, IGraphStageWithMaterializedValue<FlowShape<T, T>, NotUsed>, IGraph<FlowShape<T, T>, NotUsed>, IGraph<FlowShape<T, T>>
Type Parameters
Name Description
T

Constructors

| Improve this Doc View Source

SelectError(Func<Exception, Exception>)

Declaration
public SelectError(Func<Exception, Exception> selector)
Parameters
Type Name Description
System.Func<System.Exception, System.Exception> selector

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)

Extension Methods