Class MultiDelegateInvoker<TBaseArg, TResult>

Namespace

Utils.Reflection

Assembly

Utils.dll

Invokes multiple delegates registered for a given argument type.

public class MultiDelegateInvoker<TBaseArg, TResult> : IEnumerable<Delegate>, IEnumerable

Type Parameters

TBaseArg

The base type for the argument of the delegates.

TResult

The return type of the delegates.

Inheritance

object

MultiDelegateInvoker<TBaseArg, TResult>

Implements

IEnumerable<Delegate>

IEnumerable

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Extension Methods

EnumerableEx.FollowedBy<T>(IEnumerable<T>, params IEnumerable<T>)

EnumerableEx.HasAtLeastElements<T>(IEnumerable<T>, int)

EnumerableEx.HasManyElements<T>(IEnumerable<T>)

EnumerableEx.IsNullOrEmptyCollection<T>(IEnumerable<T>)

EnumerableEx.Pack<T>(IEnumerable<T>)

EnumerableEx.PrecededBy<T>(IEnumerable<T>, params IEnumerable<T>)

EnumerableEx.SkipTake<T>(IEnumerable<T>, int, int)

EnumerableEx.Slice<T>(IEnumerable<T>, params IEnumerable<int>)

EnumerableEx.SlideEnumerateBy<T>(IEnumerable<T>, int, int)

ObjectUtils.ComputeHash<T>(IEnumerable<T>, Func<T, int>)

ObjectUtils.IndexOf<T>(IEnumerable<T>, T)

ObjectUtils.IndexOf<T>(IEnumerable<T>, T, IEqualityComparer<T>)

ObjectUtils.IndexOf<T>(IEnumerable<T>, Func<T, bool>)

ObjectUtils.ComputeHash(IEnumerable<object>)

DataUtils.ToDbValue(object?)

MathEx.Clamp<T>(T, T, T, IComparer<T>)

FluentExtensions.Failure<T>(T)

FluentExtensions.IsEqualTo<T, CT>(T, CT)

FluentExtensions.IsGreaterOrEqualsThan<T, CT>(T, CT)

FluentExtensions.IsGreaterThan<T, CT>(T, CT)

FluentExtensions.IsIn<T>(T, params T[])

FluentExtensions.IsLowerOrEqualsThan<T, CT>(T, CT)

FluentExtensions.IsLowerThan<T, CT>(T, CT)

FluentExtensions.IsNotIn<T>(T, params T[])

FluentExtensions.IsNotNull<T>(T)

FluentExtensions.IsNull<T>(T)

FluentExtensions.Success<T>(T)

FluentExtensions.Test<T>(T, Func<T, bool>)

ObjectUtils.Between<T>(T, IComparer<T>, T, T)

ObjectUtils.Between<T>(T, IComparer<T>, T, T, bool, bool)

ObjectUtils.DoAsync<T, Result>(T, Func<T, Task<Result>>, Func<Task<Result>>)

ObjectUtils.DoAsync<T, Result>(T, Func<T, Task<Result>>, Result)

ObjectUtils.DoAsync<T, Result>(T, Func<T, Result>, Func<Result>)

ObjectUtils.DoAsync<T, Result>(T, Func<T, Result>, Result)

ObjectUtils.Do<T, Result>(T, Func<T, Result>, Func<Result>)

ObjectUtils.Do<T, Result>(T, Func<T, Result>, Result)

ObjectUtils.In<T>(T, params T[])

ObjectUtils.NotIn<T>(T, params T[])

Validations.ArgMustBe<T>(T, Func<T, bool>, string, string)

Validations.ArgMustNotBe<T>(T, Func<T, bool>, string, string)

Validations.Arg<T>(T, string)

Validations.ValueMustNotBeNull<T>(T, string)

Validations.Variable<T>(T, string)

Constructors

MultiDelegateInvoker(int)

Initializes a new instance of the MultiDelegateInvoker<TBaseArg, TResult> class.

public MultiDelegateInvoker(int parallelThreshold = 4)

Parameters

parallelThreshold int

Minimum number of delegates required to run in parallel when using InvokeSmartAsync(TBaseArg, CancellationToken).

Exceptions

ArgumentOutOfRangeException

Thrown when parallelThreshold is less than one.

Methods

Add<T>(Func<T, TResult>)

Registers a delegate function for a specific argument type derived from TBaseArg.

public void Add<T>(Func<T, TResult> function) where T : TBaseArg

Parameters

function Func<T, TResult>

The delegate to register.

Type Parameters

T

The argument type for the delegate.

GetEnumerator()

Returns an enumerator that iterates through the collection.

public IEnumerator<Delegate> GetEnumerator()

Returns

IEnumerator<Delegate>

An enumerator that can be used to iterate through the collection.

Invoke(TBaseArg)

Invokes the registered delegates sequentially for the runtime type of arg.

public TResult[] Invoke(TBaseArg arg)

Parameters

arg TBaseArg

The argument to pass to each delegate.

Returns

TResult[]

An array containing the results of each delegate call.

Exceptions

MissingMethodException

Thrown when no delegate is registered for the argument type.

InvokeAsync(TBaseArg, CancellationToken)

Invokes the registered delegates sequentially on background threads.

public Task<TResult[]> InvokeAsync(TBaseArg arg, CancellationToken cancellationToken = default)

Parameters

arg TBaseArg

The argument to pass to each delegate.

cancellationToken CancellationToken

A token used to cancel the operation.

Returns

Task<TResult[]>

A task producing an array with the results of each delegate call.

Exceptions

MissingMethodException

Thrown when no delegate is registered for the argument type.

InvokeParallelAsync(TBaseArg, CancellationToken)

Invokes the registered delegates in parallel.

public Task<TResult[]> InvokeParallelAsync(TBaseArg arg, CancellationToken cancellationToken = default)

Parameters

arg TBaseArg

The argument to pass to each delegate.

cancellationToken CancellationToken

A token used to cancel the operation.

Returns

Task<TResult[]>

A task producing an array with the results of each delegate call.

Exceptions

MissingMethodException

Thrown when no delegate is registered for the argument type.

InvokeSmartAsync(TBaseArg, CancellationToken)

Invokes the registered delegates either sequentially or in parallel depending on the configured threshold.

public Task<TResult[]> InvokeSmartAsync(TBaseArg arg, CancellationToken cancellationToken = default)

Parameters

arg TBaseArg

The argument to pass to each delegate.

cancellationToken CancellationToken

A token used to cancel the operation.

Returns

Task<TResult[]>

A task producing an array with the results of each delegate call.