Struct rumqtt::client::MqttClient

pub struct MqttClient { /* fields omitted */ }

Handle to send requests and commands to the network eventloop

Methods

impl MqttClient

pub fn start(     opts: MqttOptions ) -> Result<(Self, Receiver<Notification>), ConnectError>

Starts a new mqtt connection in a thread and returns [mqttclient] instance to send requests/commands to the event loop and a crossbeam channel receiver to receive notifications sent by the event loop.

See select.rs example [mqttclient]: struct.MqttClient.html

pub fn publish<S, V, B>(     &mut self,     topic: S,     qos: QoS,     retained: B,     payload: V ) -> Result<(), ClientError> where     S: Into<String>,     V: Into<Vec<u8>>,     B: Into<bool>,

Requests the eventloop for mqtt publish

pub fn subscribe<S>(&mut self, topic: S, qos: QoS) -> Result<(), ClientError> where     S: Into<String>,

Requests the eventloop for mqtt subscribe

pub fn unsubscribe<S>(&mut self, topic: S) -> Result<(), ClientError> where     S: Into<String>,

Requests the eventloop for mqtt unsubscribe

pub fn pause(&mut self) -> Result<(), ClientError>

Commands the network eventloop to disconnect from the broker. ReconnectOptions are not in affect here. Resume the network for reconnection

pub fn resume(&mut self) -> Result<(), ClientError>

Commands the network eventloop to reconnect to the broker and resume network io

pub fn disconnect(&mut self) -> Result<(), ClientError>

Requests the event loop for disconnection

Trait Implementations

impl Clone for MqttClient

fn clone(&self) -> MqttClient

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.