IPubSub

Namespace: SnowBank.Messaging.PubSub · interface

Implements: IDisposable

Base interface for PubSub implementations

Methods

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