Struct Client

pub struct Client { /* private fields */ }

Channel based MQTT client.

Implementations

impl Client

pub fn new(options: CreateOptions, config: ClientConfig) -> Result<Self, Error>

Create a new client using the supplied options.

pub fn tx_channel(&self) -> Sender<Event>

Get a sending channel for sending events to the client.

pub fn rx_channel(&self) -> Receiver<Event>

Get a receiving channel for consuming events from the client.

pub fn send(&self, msg: Message) -> Result<()>

Send a message.

pub fn subscribe(&self, subscription: Subscription)

Add a new subscription.

If the client is currently connected then the subscription takes effect for the connected session.

In all cases the subscription is added to the cache to be subscribed on reconnect.

pub async fn start(&self, options: ConnectOptions) -> Result<()>

Start the client using the supplied connection options.

pub async fn stop(&self) -> Result<()>

Request for the client to be stopped and wait for it to terminate.

Trait Implementations

impl Clone for Client

fn clone(&self) -> Client

Returns a duplicate of the value.

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

Performs copy-assignment from source.