Struct PublishToken 

pub struct PublishToken {
    progress_rx: Receiver<PublishProgress>,
    result_rx: Receiver<Result<ReasonCode, Error>>,
}

A token returned by MqttClient::publish that tracks the lifecycle of a publish operation.

Call progress() to inspect the current state, or wait() to await the final acknowledgement.

Fields

progress_rx: Receiver<PublishProgress>

result_rx: Receiver<Result<ReasonCode, Error>>

Implementations

impl PublishToken

pub(crate) const fn new( progress_rx: Receiver<PublishProgress>, result_rx: Receiver<Result<ReasonCode, Error>>, ) -> Self

pub fn progress(&self) -> PublishProgress

Current progress of this publish operation.

pub async fn wait(self) -> Result<ReasonCode, Error>

Wait for the publish to be fully acknowledged.

• QoS 0: resolves when the bytes have been written.
• QoS 1: resolves when PUBACK is received.
• QoS 2: resolves when PUBCOMP is received.

Errors

Returns Error::ConnectionClosed if the connection drops before the operation completes.