Class NotifyingSourceBlock<T>

Namespace

CounterpointCollective.Dataflow.Notifying

Assembly

Dataflow.Composable.dll

Notifies via Hooks when a message is sent to a target block and when a reservation is released.

The evens are sent in order.

public class NotifyingSourceBlock<T> : IReceivableSourceBlock<T>, ISourceBlock<T>, IDataflowBlock

Type Parameters

T

Inheritance

object

NotifyingSourceBlock<T>

Implements

IReceivableSourceBlock<T>

ISourceBlock<T>

IDataflowBlock

Derived

NotifyingPropagatorBlock<I, O>

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)

NotifyingExtensions.WithNotification<T>(ISourceBlock<T>, ConfigureHooks<T>)

Constructors

NotifyingSourceBlock(ISourceBlock<T>, ConfigureAsyncHooks<T>)

public NotifyingSourceBlock(ISourceBlock<T> innerBlock, ConfigureAsyncHooks<T> c)

Parameters

innerBlock ISourceBlock<T>

c ConfigureAsyncHooks<T>

NotifyingSourceBlock(ISourceBlock<T>, ConfigureHooks<T>)

public NotifyingSourceBlock(ISourceBlock<T> innerBlock, ConfigureHooks<T> c)

Parameters

innerBlock ISourceBlock<T>

c ConfigureHooks<T>

Methods

ProcessPendingEvents()

public void ProcessPendingEvents()

ProcessPendingEventsAsync()

Processes all pending events in the event queue and blocks until all events have been handled.

public ValueTask ProcessPendingEventsAsync()

Returns

ValueTask

Remarks

This method ensures that any events currently queued are processed before returning. If all events have already been processed, the method returns immediately. Otherwise, it waits until the last event currently queued is processed. This method is typically used to synchronize with the event system and guarantee that no pending events remain before proceeding.