Namespace DotnetKit.DataflowBuilder.CustomBlocks

Classes

GroupBlock<TGroupKey, TInput>

A custom propagator block that groups incoming items of type TInput by a key of type TGroupKey and emits them as batches of TInput[] once a group reaches its bounded capacity.

TimeBatchBlock<T>

A custom propagator block that groups incoming items into batches of up to batchSize items, or flushes earlier if a specified timeout duration has elapsed since the first buffered item.