Class ResizableBufferBlock<T>

Namespace

CounterpointCollective.Dataflow

Assembly

Dataflow.Composable.dll

public sealed class ResizableBufferBlock<T> : AbstractEncapsulatedPropagatorBlock<T, T>, IReceivableSourceBlock<T>, IResizablePropagatorBlock<T, T>, IPropagatorBlock<T, T>, ISourceBlock<T>, ITargetBlock<T>, IDataflowBlock

Type Parameters

T

Inheritance

object

AbstractEncapsulatedSourceBlock<T>

AbstractEncapsulatedPropagatorBlock<T, T>

ResizableBufferBlock<T>

Implements

IReceivableSourceBlock<T>

IResizablePropagatorBlock<T, T>

IPropagatorBlock<T, T>

ISourceBlock<T>

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)

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

ResizableBufferBlock(DataflowBlockOptions, Action?)

public ResizableBufferBlock(DataflowBlockOptions options, Action? onEntered = null)

Parameters

options DataflowBlockOptions

onEntered Action

Properties

BoundedCapacity

public int BoundedCapacity { get; set; }

Property Value

int

Count

public int Count { get; }

Property Value

int