Struct Client 

pub struct Client<T: Transport> { /* private fields */ }

A connected client.

Implementations

impl<T: Transport> Client<T>

pub fn connect(io: T, opts: Options) -> Result<Self>

Send CONNECT over io and wait for the broker’s answer.

pub fn session_present(&self) -> bool

Whether the broker kept a session for this client id.

pub fn stats(&self) -> Stats

pub fn publish( &mut self, topic: &str, payload: &[u8], qos: QoS, retain: bool, ) -> Result<()>

Publish a message. QoS 1 waits for the broker’s PUBACK; QoS 2 is not supported.

pub fn subscribe(&mut self, filter: &str, qos: QoS) -> Result<()>

Subscribe to a topic filter (+ and # allowed) and wait for the SUBACK.

pub fn unsubscribe(&mut self, filter: &str) -> Result<()>

Unsubscribe from a topic filter and wait for the UNSUBACK.

pub fn poll(&mut self, wait: Duration) -> Result<Option<Message>>

Wait up to wait for a message. Also answers the broker’s acknowledgements and sends a PINGREQ when the connection has been idle, so call it at least every few seconds.

pub fn disconnect(self) -> Result<T>

Say goodbye (no will message is sent) and give the transport back.

Trait Implementations

impl<T: Debug + Transport> Debug for Client<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.