Struct rumqttc_async_std::Client

pub struct Client { /* fields omitted */ }

Client to communicate with MQTT eventloop Connection.

Client is cloneable and can be used to synchronously Publish, Subscribe. Asynchronous channel handle can also be extracted if necessary

Implementations

impl Client

pub fn new(options: MqttOptions, cap: usize) -> (Client, Connection)

Create a new Client

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

Sends a MQTT Publish to the eventloop

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

Sends a MQTT Subscribe to the eventloop

pub fn subscribe_many<T>(&mut self, topics: T) -> Result<(), ClientError> where
    T: IntoIterator<Item = SubscribeFilter>, 

Sends a MQTT Subscribe for multiple topics to the eventloop

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

Sends a MQTT Unsubscribe to the eventloop

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

Sends a MQTT disconnect to the eventloop

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

Stops the eventloop right away

Trait Implementations

impl Clone for Client

fn clone(&self) -> Client

Returns a copy of the value.

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

Performs copy-assignment from source.