MemoryPubSub

Namespace: SnowBank.Messaging.PubSub · class

Implements: IPubSub, IDisposable

Constructors

MemoryPubSub

MemoryPubSub()

Methods

Dispose

void Dispose()

PublishAsync

Task PublishAsync(string channel, JsonValue message, CancellationToken ct)

Publish a message to a channel

SubscribeAsync

Task<IAsyncDisposable> SubscribeAsync(string channel, Func<string, JsonValue, CancellationToken, ValueTask> onMessageReceived, CancellationToken ct)

Subscribe to a channel