Class GuaranteedBroadcastBlock<T>

Namespace

CounterpointCollective.Dataflow

Assembly

Dataflow.Composable.dll

Guaranteed delivery of messages to NrOfSources sources. Queueing up messages in the sources until the smallest queue reached BoundedCapacity.

public sealed class GuaranteedBroadcastBlock<T> : AbstractEncapsulatedTargetBlock<T>, ITargetBlock<T>, IDataflowBlock

Type Parameters

T

Inheritance

object

AbstractEncapsulatedDataflowBlock

AbstractEncapsulatedTargetBlock<T>

GuaranteedBroadcastBlock<T>

Implements

ITargetBlock<T>

IDataflowBlock

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Extension Methods

PipelineBuilderExtensions.Pipeline<TBlock>(TBlock)

Constructors

GuaranteedBroadcastBlock(int, GuaranteedBroadcastBlockOptions, Action<int>?)

public GuaranteedBroadcastBlock(int nrOfSources, GuaranteedBroadcastBlockOptions options, Action<int>? onQueuesShrunk = null)

Parameters

nrOfSources int

options GuaranteedBroadcastBlockOptions

onQueuesShrunk Action<int>

Properties

Count

Size of the smallest/largest queue, depending on BoundedCapacityMode.

public int Count { get; }

Property Value

int

this[int]

public IReceivableSourceBlock<T> this[int index] { get; }

Parameters

index int

Property Value

IReceivableSourceBlock<T>