Struct Mqtt 

pub struct Mqtt {
    pub(crate) shared: Arc<Inner>,
    pub(crate) join_handle: JoinHandle<()>,
}

Fields

shared: Arc<Inner>

join_handle: JoinHandle<()>

Implementations

impl Mqtt

pub(crate) fn new(client_id: String, config: Config) -> Result<Self, Error>

pub async fn start(&self)

pub async fn disconnect(&self)

Disconnects the client, but keeps the worker running.

Call Mqtt::start to reconnect.

pub async fn shutdown(self)

pub fn handle(&self) -> MqttHandle