Struct CallbackSubscriptionHandle 

pub struct CallbackSubscriptionHandle { /* private fields */ }

Handle for a callback-based subscription.

Provides lifecycle management (pause/resume/cancel) for the callback task. The handle and the callback task share the same SubscriptionEntry in the registry (via SubscriptionId), so pause() / cancel() on the handle directly affects the task’s event delivery.

Dropping the handle automatically cancels the subscription and aborts the callback task.

Implementations

impl CallbackSubscriptionHandle

pub fn pause(&self) -> bool

Pauses the subscription.

While paused, events are buffered or dropped per the backpressure configuration. Returns true if the subscription was active and is now paused.

pub fn resume(&self) -> bool

Resumes a paused subscription.

Returns true if the subscription was paused and is now active.

pub fn cancel(&mut self)

Cancels the subscription and aborts the callback task.

The subscription is removed from the registry (dropping the broadcast sender) and the task is aborted as a safety net.

pub fn id(&self) -> SubscriptionId

Returns the subscription ID.

pub fn metrics(&self) -> Option<SubscriptionMetrics>

Returns subscription metrics from the registry.

pub fn is_cancelled(&self) -> bool

Returns true if the subscription has been cancelled.

Trait Implementations

impl Drop for CallbackSubscriptionHandle

fn drop(&mut self)

Executes the destructor for this type.