Class GroupAdjacentBlock<T, K, V>

Namespace

CounterpointCollective.Dataflow

Assembly

Dataflow.Composable.dll

public class GroupAdjacentBlock<T, K, V> : AbstractEncapsulatedPropagatorBlock<T, IGrouping<K, V>>, IReceivableSourceBlock<IGrouping<K, V>>, IPropagatorBlock<T, IGrouping<K, V>>, ISourceBlock<IGrouping<K, V>>, ITargetBlock<T>, IDataflowBlock

Type Parameters

T

K

V

Inheritance

object

AbstractEncapsulatedSourceBlock<IGrouping<K, V>>

AbstractEncapsulatedPropagatorBlock<T, IGrouping<K, V>>

GroupAdjacentBlock<T, K, V>

Implements

IReceivableSourceBlock<IGrouping<K, V>>

IPropagatorBlock<T, IGrouping<K, V>>

ISourceBlock<IGrouping<K, V>>

ITargetBlock<T>

IDataflowBlock

Inherited Members

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

GroupAdjacentBlock(Func<T, K>, Func<T, V>, ExecutionDataflowBlockOptions, bool)

public GroupAdjacentBlock(Func<T, K> keySelector, Func<T, V> valueSelector, ExecutionDataflowBlockOptions options, bool flushOnIdle = false)

Parameters

keySelector Func<T, K>

valueSelector Func<T, V>

options ExecutionDataflowBlockOptions

flushOnIdle bool

Properties

Count

public int Count { get; }

Property Value

int