Class Broadcast<T>

Fan-out the stream to several streams emitting each incoming upstream element to all downstream consumers. It will not shut down until the subscriptions for at least two downstream subscribers have been established.

Emits when all of the outputs stops backpressuring and there is an input element available

Backpressures when any of the outputs backpressure

Completes when upstream completes

Cancels when If eagerCancel is enabled: when any downstream cancels; otherwise: when all downstreams cancel

Inheritance

object

GraphStageWithMaterializedValue<UniformFanOutShape<T, T>, NotUsed>

GraphStage<UniformFanOutShape<T, T>>

Broadcast<T>

Implements

IGraphStageWithMaterializedValue<UniformFanOutShape<T, T>, NotUsed>

IGraph<UniformFanOutShape<T, T>, NotUsed>

IGraph<UniformFanOutShape<T, T>>

Inherited Members

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

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

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

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

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

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

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

GraphStageWithMaterializedValue<UniformFanOutShape<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 Broadcast<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

Broadcast(int, bool)

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

Declaration

public Broadcast(int outputPorts, bool eagerCancel = false)

Parameters

Type	Name	Description
int	outputPorts	TBD
bool	eagerCancel	TBD

Exceptions

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

Fields

In

TBD

Declaration

public readonly Inlet<T> In

Field Value

Type	Description
Inlet<T>

Properties

InitialAttributes

TBD

Declaration

protected override Attributes InitialAttributes { get; }

Property Value

Type	Description
Attributes

Overrides

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

Shape

TBD

Declaration

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

Property Value

Type	Description
UniformFanOutShape<T, T>

Overrides

GraphStageWithMaterializedValue<UniformFanOutShape<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<UniformFanOutShape<T, T>>.CreateLogic(Attributes)

Out(int)

TBD

Declaration

public Outlet<T> Out(int id)

Parameters

Type	Name	Description
int	id	TBD

Returns

Type	Description
Outlet<T>	TBD

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)