Class NotifyingSourceBlockAsyncHooks<T>

Namespace

CounterpointCollective.Dataflow.Notifying

Assembly

Dataflow.Composable.dll

public record NotifyingSourceBlockAsyncHooks<T> : NotifyingSourceBlockHooks, IEquatable<NotifyingSourceBlockHooks>, IEquatable<NotifyingSourceBlockAsyncHooks<T>>

Type Parameters

T

Inheritance

object

NotifyingSourceBlockHooks

NotifyingSourceBlockAsyncHooks<T>

Implements

IEquatable<NotifyingSourceBlockHooks>

IEquatable<NotifyingSourceBlockAsyncHooks<T>>

Inherited Members

NotifyingSourceBlockHooks.ConfigureDispatching

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

NotifyingSourceBlockAsyncHooks(ISourceBlock<T>)

public NotifyingSourceBlockAsyncHooks(ISourceBlock<T> SourceBlock)

Parameters

SourceBlock ISourceBlock<T>

Properties

OnDeliveringMessagesAsync

This Action will be executed when a messages are sent from the source block.

public Func<int, ValueTask>? OnDeliveringMessagesAsync { get; set; }

Property Value

Func<int, ValueTask>

OnReservationReleasedAsync

This Action will be executed when a linked target released its reservation.

public Func<ValueTask>? OnReservationReleasedAsync { get; set; }

Property Value

Func<ValueTask>

SourceBlock

public ISourceBlock<T> SourceBlock { get; init; }

Property Value

ISourceBlock<T>