Class BoundedPropagatorBlock<I, O>

Namespace

CounterpointCollective.Dataflow

Assembly

Dataflow.Composable.dll

A wrapper that enforces a BoundedCapacity on an arbitrary IPropagatorBlock<TInput, TOutput>. See also its base class BoundedTargetBlock<T>.

public class BoundedPropagatorBlock<I, O> : BoundedTargetBlock<I>, IReceivableSourceBlock<O>, IResizablePropagatorBlock<I, O>, IPropagatorBlock<I, O>, ISourceBlock<O>, ITargetBlock<I>, IDataflowBlock

Type Parameters

I

O

Inheritance

object

AbstractEncapsulatedDataflowBlock

AbstractEncapsulatedTargetBlock<I>

BoundedTargetBlock<I>

BoundedPropagatorBlock<I, O>

Implements

IReceivableSourceBlock<O>

IResizablePropagatorBlock<I, O>

IPropagatorBlock<I, O>

ISourceBlock<O>

ITargetBlock<I>

IDataflowBlock

Inherited Members

BoundedTargetBlock<I>.Count

BoundedTargetBlock<I>.IsCompletionRequested

BoundedTargetBlock<I>.InputCompletion

BoundedTargetBlock<I>.CreateExit<TO>(ISourceBlock<TO>)

BoundedTargetBlock<I>.AdjustCount(int)

BoundedTargetBlock<I>.BoundedCapacity

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Extension Methods

PipelineBuilderExtensions.Pipeline<TBlock>(TBlock)

BoundedPropagatorBlockExtensions.WithBoundedCapacity<I, O>(IPropagatorBlock<I, O>, int)

NotifyingExtensions.WithNotification<I, O>(IPropagatorBlock<I, O>, ConfigureHooks<O>)

ParallelDataflowBlockExtensions.Par<TInput, T1, T2, TOutput>(IPropagatorBlock<TInput, T1>, IPropagatorBlock<TInput, T2>, Func<T1, T2, TOutput>, GuaranteedBroadcastBlockOptions)

NotifyingExtensions.WithNotification<T>(ISourceBlock<T>, ConfigureHooks<T>)

Constructors

BoundedPropagatorBlock(IPropagatorBlock<I, O>, int, Action?, Action?)

public BoundedPropagatorBlock(IPropagatorBlock<I, O> inner, int boundedCapacity = -1, Action? onEntering = null, Action? onEntered = null)

Parameters

inner IPropagatorBlock<I, O>

boundedCapacity int

onEntering Action

onEntered Action

BoundedPropagatorBlock(ITargetBlock<I>, ISourceBlock<O>, int, Action?, Action?)

public BoundedPropagatorBlock(ITargetBlock<I> entrance, ISourceBlock<O> exit, int boundedCapacity = -1, Action? onEntering = null, Action? onEntered = null)

Parameters

entrance ITargetBlock<I>

exit ISourceBlock<O>

boundedCapacity int

onEntering Action

onEntered Action