Struct paho_mqtt::client::Client

pub struct Client { /* fields omitted */ }

Methods

impl Client

fn new<T>(opts: T) -> MqttResult<Client> where
    T: Into<CreateOptions>, 

fn connect<T: Into<Option<ConnectOptions>>>(
    &self,
    opt_opts: T
) -> MqttResult<()>

fn disconnect<T: Into<Option<DisconnectOptions>>>(
    &self,
    opt_opts: T
) -> MqttResult<()>

fn disconnect_after(&self, timeout: Duration) -> MqttResult<()>

fn reconnect(&self) -> MqttResult<()>

fn is_connected(&self) -> bool

fn publish(&self, msg: Message) -> MqttResult<()>

fn subscribe(&self, topic: &str, qos: i32) -> MqttResult<()>

fn subscribe_many(&self, topics: Vec<String>, qos: Vec<i32>) -> MqttResult<()>

fn unsubscribe(&self, topic: &str) -> MqttResult<()>

fn unsubscribe_many(&self, topics: Vec<String>) -> MqttResult<()>

fn start_consuming(&mut self) -> Receiver<Message>