Interface IResizablePropagatorBlock<TInput, TOutput>

Namespace

CounterpointCollective

Assembly

Dataflow.Composable.dll

public interface IResizablePropagatorBlock<in TInput, out TOutput> : IPropagatorBlock<TInput, TOutput>, ISourceBlock<TOutput>, ITargetBlock<TInput>, IDataflowBlock

Type Parameters

TInput

TOutput

Inherited Members

ISourceBlock<TOutput>.ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, out bool)

ISourceBlock<TOutput>.LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions)

ISourceBlock<TOutput>.ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)

ISourceBlock<TOutput>.ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)

ITargetBlock<TInput>.OfferMessage(DataflowMessageHeader, TInput, ISourceBlock<TInput>, bool)

IDataflowBlock.Complete()

IDataflowBlock.Fault(Exception)

IDataflowBlock.Completion

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>)

Properties

BoundedCapacity

int BoundedCapacity { get; set; }

Property Value

int

Count

int Count { get; }

Property Value

int