Class Aggregator<TKey, TItem, TResult>.Builder

Namespace

PatternKit.Messaging.Routing

Assembly

PatternKit.Core.dll

Fluent builder for Aggregator<TKey, TItem, TResult>.

public sealed class Aggregator<TKey, TItem, TResult>.Builder

Inheritance

object

Aggregator<TKey, TItem, TResult>.Builder

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Methods

Build()

Builds an immutable aggregator.

public Aggregator<TKey, TItem, TResult> Build()

Returns

Aggregator<TKey, TItem, TResult>

CompleteWhen(CompletionPolicy)

Sets the completion policy.

public Aggregator<TKey, TItem, TResult>.Builder CompleteWhen(Aggregator<TKey, TItem, TResult>.CompletionPolicy completionPolicy)

Parameters

completionPolicy Aggregator<TKey, TItem, TResult>.CompletionPolicy

Returns

Aggregator<TKey, TItem, TResult>.Builder

Duplicates(DuplicateMessagePolicy)

Sets duplicate handling for messages with the same message id.

public Aggregator<TKey, TItem, TResult>.Builder Duplicates(DuplicateMessagePolicy duplicatePolicy)

Parameters

duplicatePolicy DuplicateMessagePolicy

Returns

Aggregator<TKey, TItem, TResult>.Builder

KeyBy(KeySelector)

Sets the aggregation key selector.

public Aggregator<TKey, TItem, TResult>.Builder KeyBy(Aggregator<TKey, TItem, TResult>.KeySelector keySelector)

Parameters

keySelector Aggregator<TKey, TItem, TResult>.KeySelector

Returns

Aggregator<TKey, TItem, TResult>.Builder

Project(ResultFactory)

Sets the result factory.

public Aggregator<TKey, TItem, TResult>.Builder Project(Aggregator<TKey, TItem, TResult>.ResultFactory resultFactory)

Parameters

resultFactory Aggregator<TKey, TItem, TResult>.ResultFactory

Returns

Aggregator<TKey, TItem, TResult>.Builder