Method Create

Namespace

SodaFlow.Async

Assembly

SodaFlow.Async.dll

Create<TGroup>(Func<TInput, TGroup>, IEqualityComparer<TGroup>?)

Builds a strategy with one queue for each group. getGroup puts each input in a group. In one group, a subsequent send goes behind the sends before it, as Queue() does. Two different groups do not wait for each other.

public AsyncConcurrencyStrategyBase<TInput> Create<TGroup>(Func<TInput, TGroup> getGroup, IEqualityComparer<TGroup>? groupComparer = null) where TGroup : notnull

Parameters

getGroup Func<TInput, TGroup>

Calculates the group key of an input value.

groupComparer IEqualityComparer<TGroup>

An optional equality comparer for the group keys. The default is Default.

Returns

AsyncConcurrencyStrategyBase<TInput>

Type Parameters

TGroup