Class Balance<T>

Fan-out the stream to several streams. Each upstream element is emitted to the first available downstream consumer. It will not shut down until the subscriptions for at least two downstream subscribers have been established.

A Balance<T> has one In port and 2 or more Out(Int32) ports.

Emits when any of the outputs stops backpressuring; emits the element to the first available output

Backpressures when all of the outputs backpressure

Completes when upstream completes

Cancels when all downstreams cancel

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

TBD

Constructors

| Improve this Doc View Source

Balance(Int32, Boolean)

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

Declaration
public Balance(int outputPorts, bool waitForAllDownstreams = false)
Parameters
Type Name Description
Int32 outputPorts

TBD
Boolean waitForAllDownstreams

TBD
Exceptions
Type Condition
ArgumentException

This exception is thrown when the specified outputPorts is less than one.

Properties

| Improve this Doc View Source

In

TBD

Declaration
public Inlet<T> In { get; }
Property Value
Type Description
Inlet<T>
| Improve this Doc View Source

InitialAttributes

TBD

Declaration
protected override Attributes InitialAttributes { get; }
Property Value
Type Description
Attributes
Overrides
Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.UniformFanOutShape<T, T>, Akka.NotUsed>.InitialAttributes
| Improve this Doc View Source

Shape

TBD

Declaration
public override UniformFanOutShape<T, T> Shape { get; }
Property Value
Type Description
UniformFanOutShape<T, T>
Overrides
Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.UniformFanOutShape<T, T>, Akka.NotUsed>.Shape

Methods

| Improve this Doc 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
Akka.Streams.Stage.GraphStage<Akka.Streams.UniformFanOutShape<T, T>>.CreateLogic(Akka.Streams.Attributes)
| Improve this Doc View Source

Out(Int32)

TBD

Declaration
public Outlet<T> Out(int id)
Parameters
Type Name Description
Int32 id

TBD
Returns
Type Description
Outlet<T>

TBD
| Improve this Doc View Source

ToString()

TBD

Declaration
public override string ToString()
Returns
Type Description
String

TBD
Overrides

Implements

Extension Methods