IMessageDispatcher<TMessage>

Namespace: SnowBank.Messaging · interface

Implements: IAsyncDisposable

Methods

Complete

void Complete()

Dispatch

void Dispatch(TMessage message)

void Dispatch(ReadOnlyMemory<TMessage> batch)

DrainAsync

Task DrainAsync(bool final, CancellationToken ct)

Start

void Start()