MessageDispatcher

Namespace: SnowBank.Messaging · class

Methods

Buffered

static IMessageDispatcher<TMessage> Buffered<TMessage, TState>(TState state, Func<ReadOnlyMemory<TMessage>, TState, CancellationToken, Task> handler)

Combine

static IMessageDispatcher<TMessage> Combine<TMessage>(IEnumerable<IMessageDispatcher<TMessage>> dispatchers)

Direct

static IMessageDispatcher<TMessage> Direct<TMessage, TState>(TState state, Action<TMessage, TState> one, Action<ReadOnlyMemory<TMessage>, TState> many)

Null

static IMessageDispatcher<TMessage> Null<TMessage>()