Struct MqttHandle 

pub struct MqttHandle {
    pub(crate) shared: Arc<Inner>,
}

Fields

shared: Arc<Inner>

Implementations

impl MqttHandle

pub fn client_id(&self) -> Arc<str>

pub fn is_connected(&self) -> bool

pub fn watch_state(&self) -> ConnectionStateWatch

pub async fn health(&self) -> Report

pub async fn set_desired_state(&self, state: ConnectionState)

pub async fn subscribe(&self, topic: &str, qos: i32) -> Subscription

pub fn queue_publish(&self, msg: Message) -> Result<DeliveryToken, Error>

pub fn has_persistence(&self) -> bool

Returns true if persistence is enabled.