Class NotifyingPropagatorBlock<I, O>

Namespace

CounterpointCollective.Dataflow.Notifying

Assembly

Dataflow.Composable.dll

public class NotifyingPropagatorBlock<I, O> : NotifyingSourceBlock<O>, IReceivableSourceBlock<O>, IPropagatorBlock<I, O>, ISourceBlock<O>, ITargetBlock<I>, IDataflowBlock

Type Parameters

I

O

Inheritance

object

NotifyingSourceBlock<O>

NotifyingPropagatorBlock<I, O>

Implements

IReceivableSourceBlock<O>

IPropagatorBlock<I, O>

ISourceBlock<O>

ITargetBlock<I>

IDataflowBlock

Inherited Members

NotifyingSourceBlock<O>.ProcessPendingEventsAsync()

NotifyingSourceBlock<O>.ProcessPendingEvents()

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

NotifyingPropagatorBlock(IPropagatorBlock<I, O>, ConfigureHooks<O>)

public NotifyingPropagatorBlock(IPropagatorBlock<I, O> inner, ConfigureHooks<O> hooks)

Parameters

inner IPropagatorBlock<I, O>

hooks ConfigureHooks<O>