MultipleMessageDispatcher<TMessage>

Namespace: SnowBank.Messaging · class

Implements: IMessageDispatcher<TMessage>, IAsyncDisposable

Dispatch messages to multiple dispatchers

Constructors

MultipleMessageDispatcher<TMessage>

MultipleMessageDispatcher<TMessage>(IMessageDispatcher<TMessage>[] dispatchers)

Properties

Dispatchers

IMessageDispatcher<TMessage>[] Dispatchers { get; set; }

Methods

Complete

void Complete()

Dispatch

void Dispatch(TMessage message)

void Dispatch(ReadOnlyMemory<TMessage> batch)

DisposeAsync

ValueTask DisposeAsync()

DrainAsync

Task DrainAsync(bool final, CancellationToken ct)

Start

void Start()