Class AsyncScatterGather<TRequest, TResponse, TResult>.Builder

Namespace

PatternKit.Messaging.Routing

Assembly

PatternKit.Core.dll

Fluent builder for AsyncScatterGather<TRequest, TResponse, TResult>.

public sealed class AsyncScatterGather<TRequest, TResponse, TResult>.Builder

Inheritance

object

AsyncScatterGather<TRequest, TResponse, 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 async scatter-gather.

public AsyncScatterGather<TRequest, TResponse, TResult> Build()

Returns

AsyncScatterGather<TRequest, TResponse, TResult>

CompleteWith(CompletionStrategy)

Sets the completion strategy (default: All).

public AsyncScatterGather<TRequest, TResponse, TResult>.Builder CompleteWith(CompletionStrategy strategy)

Parameters

strategy CompletionStrategy

Returns

AsyncScatterGather<TRequest, TResponse, TResult>.Builder

Recipient(string, AsyncRecipientHandler)

Adds a named async recipient.

public AsyncScatterGather<TRequest, TResponse, TResult>.Builder Recipient(string name, AsyncScatterGather<TRequest, TResponse, TResult>.AsyncRecipientHandler handler)

Parameters

name string

handler AsyncScatterGather<TRequest, TResponse, TResult>.AsyncRecipientHandler

Returns

AsyncScatterGather<TRequest, TResponse, TResult>.Builder

WithAggregator(ResponseAggregator)

Sets the aggregation delegate.

public AsyncScatterGather<TRequest, TResponse, TResult>.Builder WithAggregator(AsyncScatterGather<TRequest, TResponse, TResult>.ResponseAggregator aggregator)

Parameters

aggregator AsyncScatterGather<TRequest, TResponse, TResult>.ResponseAggregator

Returns

AsyncScatterGather<TRequest, TResponse, TResult>.Builder