Struct HttpNotificationSubscription 

pub struct HttpNotificationSubscription { /* private fields */ }

A bounded independently read HTTP subscription. Closing joins its one worker; dropping signals cancellation and aborts that same task. Received events never execute SQL.

Implementations

impl HttpNotificationSubscription

pub fn initial_ready(&self) -> &NotificationReady

pub fn identity(&self) -> &NotificationIdentity

Identity visible to this consumer; advances when Reconnected is consumed, never ahead of its gap event.

pub fn cancellation(&self) -> NotificationCancellation

pub async fn next_event(&mut self) -> Result<Option<NotificationEvent>, Error>

Cancelling this receive future leaves the subscription alive. Close/drop or its explicit cancellation signal stops the owned transport.

pub async fn close(&mut self) -> Result<(), Error>

Completes local worker/response cleanup. It does not acknowledge a remote listener-cleanup transaction.

Trait Implementations

impl Debug for HttpNotificationSubscription

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.