Struct NotificationDispatcher 

pub struct NotificationDispatcher { /* private fields */ }

A notification dispatcher that routes PG notifications to subscribers.

Wraps a tokio broadcast channel. Multiple receivers can subscribe, and each receives all notifications. Used internally by the listener to fan out notifications from a single dedicated connection.

Implementations

impl NotificationDispatcher

pub fn new() -> Self

Create a new dispatcher with the default buffer capacity.

pub fn with_capacity(capacity: usize) -> Self

Create a new dispatcher with a specific buffer capacity.

pub fn subscribe(&self) -> NotificationReceiver

Subscribe to receive notifications.

Returns a receiver that will get all notifications dispatched after this point.

pub fn dispatch(&self, notification: Notification) -> usize

Dispatch a notification to all subscribers.

Returns the number of receivers that got the message. Returns 0 if there are no active subscribers (which is fine).

pub fn add_channel(&mut self, channel: String)

Track that we’re listening on a channel.

pub fn remove_channel(&mut self, channel: &str)

Remove a tracked channel.

pub fn channels(&self) -> &HashSet<String>

Get all tracked channel names (for re-subscribing on reconnect).

pub fn subscriber_count(&self) -> usize

Number of active subscribers.

Trait Implementations

impl Default for NotificationDispatcher

fn default() -> Self

Returns the “default value” for a type.