Struct Reconnect 

pub struct Reconnect { /* private fields */ }

Handle to a background reconnect loop.

Spawns a tokio task that connects, waits for session close, then reconnects with exponential backoff. status reports connection changes; closed waits for the loop to stop. Dropping the handle aborts the background task.

Implementations

impl Reconnect

pub fn poll_status(&mut self, waiter: &Waiter) -> Poll<Result<Status>>

Poll for the next connection status change since this handle last reported one.

Ready(Ok(status)) on a change, Ready(Err) once the loop has stopped (the give-up error, or a generic one when the handle is dropped), Pending otherwise.

pub async fn status(&mut self) -> Result<Status>

Wait until the connection status changes from what this handle last reported.

Returns the current Status. The loop alternates Connected/Disconnected, so successive calls alternate too; but a status that flips and flips back before the caller polls is reported once. This tracks the current state, not every edge.

pub fn poll_closed(&self, waiter: &Waiter) -> Poll<Result<()>>

Poll whether the reconnect loop has stopped.

Ready(Err) if it permanently gave up (reconnect timeout exceeded), Ready(Ok(())) if stopped by dropping the handle, Pending while it’s still running.

pub async fn closed(&self) -> Result<()>

Wait until the reconnect loop stops.

Trait Implementations

impl Drop for Reconnect

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.