Struct MessageListenerHandle 

pub struct MessageListenerHandle { /* private fields */ }

Owns the background poller task driving a push-mode consumer. Mirrors the lifetime semantics of crate::TableView’s drain task: dropping the handle aborts the poller; Self::close awaits a clean stop.

The poller terminates on its own when an explicit or terminal remote close makes receive() return an error. Dropping this handle aborts the poller, then task unwinding drops its owned consumer clone. That clone triggers a best-effort close only when it is the final clone; if other consumer clones remain, this drop stages no close.

Implementations

impl MessageListenerHandle

pub fn is_running(&self) -> bool

true while the poller task is still running. Flips to false once the consumer is closed (the loop broke) or the handle has been Self::closed / dropped.

pub async fn close(&self)

Stop the poller task and wait for it to unwind. Idempotent — a second call (or a call after the consumer already closed the loop) is a no-op.

Trait Implementations

impl Debug for MessageListenerHandle

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

Formats the value using the given formatter.

impl Drop for MessageListenerHandle

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.