Class OrElse<T>

Takes two streams and passes the first through, the secondary stream is only passed through if the primary stream completes without passing any elements through. When the first element is passed through from the primary the secondary is cancelled. Both incoming streams are materialized when the stage is materialized.

On errors the stage is failed regardless of source of the error.

'''Emits when''' element is available from primary stream or the primary stream closed without emitting any elements and an element is available from the secondary stream

'''Backpressures when''' downstream backpressures

'''Completes when''' the primary stream completes after emitting at least one element, when the primary stream completes without emitting and the secondary stream already has completed or when the secondary stream completes

'''Cancels when''' downstream cancels

Inheritance

object

GraphStageWithMaterializedValue<UniformFanInShape<T, T>, NotUsed>

GraphStage<UniformFanInShape<T, T>>

OrElse<T>

Implements

IGraphStageWithMaterializedValue<UniformFanInShape<T, T>, NotUsed>

IGraph<UniformFanInShape<T, T>, NotUsed>

IGraph<UniformFanInShape<T, T>>

Inherited Members

GraphStage<UniformFanInShape<T, T>>.CreateLogicAndMaterializedValue(Attributes)

GraphStageWithMaterializedValue<UniformFanInShape<T, T>, NotUsed>.Shape

GraphStageWithMaterializedValue<UniformFanInShape<T, T>, NotUsed>.WithAttributes(Attributes)

GraphStageWithMaterializedValue<UniformFanInShape<T, T>, NotUsed>.CreateLogicAndMaterializedValue(Attributes)

GraphStageWithMaterializedValue<UniformFanInShape<T, T>, NotUsed>.Module

GraphStageWithMaterializedValue<UniformFanInShape<T, T>, NotUsed>.AddAttributes(Attributes)

GraphStageWithMaterializedValue<UniformFanInShape<T, T>, NotUsed>.Named(string)

GraphStageWithMaterializedValue<UniformFanInShape<T, T>, NotUsed>.Async()

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

Namespace: Akka.Streams.Dsl

Assembly: Akka.Streams.dll

Syntax

public sealed class OrElse<T> : GraphStage<UniformFanInShape<T, T>>, IGraphStageWithMaterializedValue<UniformFanInShape<T, T>, NotUsed>, IGraph<UniformFanInShape<T, T>, NotUsed>, IGraph<UniformFanInShape<T, T>>

Type Parameters

Name	Description
T	TBD

Constructors

OrElse()

Initializes a new instance of the OrElse<T> class.

Declaration

public OrElse()

Properties

InitialAttributes

TBD

Declaration

protected override Attributes InitialAttributes { get; }

Property Value

Type	Description
Attributes

Overrides

GraphStageWithMaterializedValue<UniformFanInShape<T, T>, NotUsed>.InitialAttributes

Out

TBD

Declaration

public Outlet<T> Out { get; }

Property Value

Type	Description
Outlet<T>

Primary

TBD

Declaration

public Inlet<T> Primary { get; }

Property Value

Type	Description
Inlet<T>

Secondary

TBD

Declaration

public Inlet<T> Secondary { get; }

Property Value

Type	Description
Inlet<T>

Shape

TBD

Declaration

public override UniformFanInShape<T, T> Shape { get; }

Property Value

Type	Description
UniformFanInShape<T, T>

Overrides

GraphStageWithMaterializedValue<UniformFanInShape<T, T>, NotUsed>.Shape

Methods

CreateLogic(Attributes)

TBD

Declaration

protected override GraphStageLogic CreateLogic(Attributes inheritedAttributes)

Parameters

Type	Name	Description
Attributes	inheritedAttributes	TBD

Returns

Type	Description
GraphStageLogic	TBD

Overrides

GraphStage<UniformFanInShape<T, T>>.CreateLogic(Attributes)

ToString()

TBD

Declaration

public override string ToString()

Returns

Type	Description
string	TBD

Overrides

object.ToString()

Implements

IGraphStageWithMaterializedValue<TShape, TMaterialized>

IGraph<TShape, TMaterialized>

IGraph<TShape>

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(object)