DirectMessageDispatcher<TMessage, TState>

Namespace: SnowBank.Messaging · class

Implements: IMessageDispatcher<TMessage>, IAsyncDisposable

Dispatch messages directly, using the caller's thread

Constructors

DirectMessageDispatcher<TMessage, TState>

DirectMessageDispatcher<TMessage, TState>(TState state, Action<TMessage, TState> one, Action<ReadOnlyMemory<TMessage>, TState> many)

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