Struct EventLoopHandle 

pub struct EventLoopHandle {
    shutdown_tx: Sender<()>,
    task: JoinHandle<()>,
}

Owns the connection event loop and controls its lifecycle.

Returned by ClientBuilder::start next to the MqttClient. Client handles clone freely and only issue operations; this handle is unique, and the event loop runs exactly as long as it lives: dropping every client handle does not stop the session.

Call stop for a graceful shutdown. Dropping the handle without calling it also shuts the event loop down, but without sending a DISCONNECT packet, so the broker treats the connection as lost and publishes the will (if one is configured).

Fields

shutdown_tx: Sender<()>

task: JoinHandle<()>

Implementations

impl EventLoopHandle

pub(crate) const fn new(shutdown_tx: Sender<()>, task: JoinHandle<()>) -> Self

pub async fn stop(self)

Sends a graceful DISCONNECT and waits for the event loop to exit.

The shutdown signal is delivered out of band, so it takes effect even while the event loop has paused command intake for backpressure. Commands already accepted are still applied before the DISCONNECT is sent. Completes once the event loop has fully exited (connection closed, journal writer flushed); if it already exited on its own, completes immediately.