Class ResizableBatchTransformBlock<I, O>

Namespace

CounterpointCollective.Dataflow

Assembly

Dataflow.Composable.dll

public sealed class ResizableBatchTransformBlock<I, O> : AbstractEncapsulatedPropagatorBlock<I, O>, IReceivableSourceBlock<O>, IResizablePropagatorBlock<I, O>, IPropagatorBlock<I, O>, ISourceBlock<O>, ITargetBlock<I>, IDataflowBlock

Type Parameters

I

O

Inheritance

object

AbstractEncapsulatedSourceBlock<O>

AbstractEncapsulatedPropagatorBlock<I, O>

ResizableBatchTransformBlock<I, O>

Implements

IReceivableSourceBlock<O>

IResizablePropagatorBlock<I, O>

IPropagatorBlock<I, O>

ISourceBlock<O>

ITargetBlock<I>

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

ResizableBatchTransformBlock(Func<I[], Task<IEnumerable<O>>>, int, ExecutionDataflowBlockOptions?)

public ResizableBatchTransformBlock(Func<I[], Task<IEnumerable<O>>> transform, int initialBatchSize, ExecutionDataflowBlockOptions? options = null)

Parameters

transform Func<I[], Task<IEnumerable<O>>>

initialBatchSize int

options ExecutionDataflowBlockOptions

Properties

BatchSize

public int BatchSize { get; set; }

Property Value

int

BoundedCapacity

public int BoundedCapacity { get; set; }

Property Value

int

Count

public int Count { get; }

Property Value

int

InProgressCount

public int InProgressCount { get; }

Property Value

int

InputCount

public int InputCount { get; }

Property Value

int

IsBottleneckCurrently

public bool IsBottleneckCurrently { get; }

Property Value

bool

IsFull

public bool IsFull { get; }

Property Value

bool

LongestWait

public TimeSpan LongestWait { get; }

Property Value

TimeSpan

OnBatch

public Func<ResizableBatchTransformBlock<I, O>, IList<I>, IDisposable>? OnBatch { get; set; }

Property Value

Func<ResizableBatchTransformBlock<I, O>, IList<I>, IDisposable>

OnBatchSizeChanged

public Action<int>? OnBatchSizeChanged { get; set; }

Property Value

Action<int>

OutputCount

public int OutputCount { get; }

Property Value

int

SourceSide

protected override ISourceBlock<O> SourceSide { get; }

Property Value

ISourceBlock<O>

TargetSide

protected override ITargetBlock<I> TargetSide { get; }

Property Value

ITargetBlock<I>