Class Aggregator<TKey, TItem, TResult>

Namespace

PatternKit.Messaging.Routing

Assembly

PatternKit.Core.dll

In-process aggregator that collects related messages until a completion policy is satisfied.

public sealed class Aggregator<TKey, TItem, TResult> where TKey : notnull

Type Parameters

TKey

TItem

TResult

Inheritance

object

Aggregator<TKey, TItem, TResult>

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Properties

OpenGroupCount

Returns the number of currently open groups.

public int OpenGroupCount { get; }

Property Value

int

Methods

Add(Message<TItem>, MessageContext?)

Adds a message to its group and returns a completed result when the completion policy is satisfied.

public AggregationResult<TKey, TResult> Add(Message<TItem> message, MessageContext? context = null)

Parameters

message Message<TItem>

context MessageContext

Returns

AggregationResult<TKey, TResult>

Create()

Creates a new aggregator builder.

public static Aggregator<TKey, TItem, TResult>.Builder Create()

Returns

Aggregator<TKey, TItem, TResult>.Builder