BufferedMessageDispatcher<TMessage, TState>

Namespace: SnowBank.Messaging · class

Implements: IMessageDispatcher<TMessage>, IAsyncDisposable

Dispatch messages using a buffered channel for async processing

Constructors

BufferedMessageDispatcher<TMessage, TState>

BufferedMessageDispatcher<TMessage, TState>(TState state, Func<ReadOnlyMemory<TMessage>, TState, CancellationToken, Task> handler)

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()