Class NonOrderPreservingChoiceBlock<TInput, TOutput>

Namespace

CounterpointCollective.Dataflow

Assembly

Dataflow.Composable.dll

public class NonOrderPreservingChoiceBlock<TInput, TOutput> : AbstractEncapsulatedPropagatorBlock<TInput, TOutput>, IReceivableSourceBlock<TOutput>, IResizablePropagatorBlock<TInput, TOutput>, IPropagatorBlock<TInput, TOutput>, ISourceBlock<TOutput>, ITargetBlock<TInput>, IDataflowBlock

Type Parameters

TInput

TOutput

Inheritance

object

AbstractEncapsulatedSourceBlock<TOutput>

AbstractEncapsulatedPropagatorBlock<TInput, TOutput>

NonOrderPreservingChoiceBlock<TInput, TOutput>

Implements

IReceivableSourceBlock<TOutput>

IResizablePropagatorBlock<TInput, TOutput>

IPropagatorBlock<TInput, TOutput>

ISourceBlock<TOutput>

ITargetBlock<TInput>

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

NonOrderPreservingChoiceBlock(Predicate<TInput>, IPropagatorBlock<TInput, TOutput>, IPropagatorBlock<TInput, TOutput>, ExecutionDataflowBlockOptions?)

public NonOrderPreservingChoiceBlock(Predicate<TInput> predicate, IPropagatorBlock<TInput, TOutput> thenBlock, IPropagatorBlock<TInput, TOutput> elseBlock, ExecutionDataflowBlockOptions? options = null)

Parameters

predicate Predicate<TInput>

thenBlock IPropagatorBlock<TInput, TOutput>

elseBlock IPropagatorBlock<TInput, TOutput>

options ExecutionDataflowBlockOptions

NonOrderPreservingChoiceBlock(IPropagatorBlock<TInput, (bool P, TInput V)>, IPropagatorBlock<TInput, TOutput>, IPropagatorBlock<TInput, TOutput>, DataflowBlockOptions?)

public NonOrderPreservingChoiceBlock(IPropagatorBlock<TInput, (bool P, TInput V)> conditionCheckBlock, IPropagatorBlock<TInput, TOutput> thenBlock, IPropagatorBlock<TInput, TOutput> elseBlock, DataflowBlockOptions? options = null)

Parameters

conditionCheckBlock IPropagatorBlock<TInput, (bool P, TInput V)>

thenBlock IPropagatorBlock<TInput, TOutput>

elseBlock IPropagatorBlock<TInput, TOutput>

options DataflowBlockOptions

Properties

BoundedCapacity

public int BoundedCapacity { get; set; }

Property Value

int

Count

public int Count { get; }

Property Value

int

InputCount

public int InputCount { get; }

Property Value

int

OutputCount

public int OutputCount { get; }

Property Value

int

SourceSide

protected override ISourceBlock<TOutput> SourceSide { get; }

Property Value

ISourceBlock<TOutput>

TargetSide

protected override ITargetBlock<TInput> TargetSide { get; }

Property Value

ITargetBlock<TInput>