Struct MqttClient 

pub struct MqttClient<'a, T, const MAX_TOPICS: usize, const BUF_SIZE: usize>
where
    T: MqttTransport,
{ /* private fields */ }

The asynchronous MQTT client.

Implementations

impl<'a, T, const MAX_TOPICS: usize, const BUF_SIZE: usize> MqttClient<'a, T, MAX_TOPICS, BUF_SIZE>

where T: MqttTransport,

pub fn new(transport: T, options: MqttOptions<'a>) -> Self

pub async fn connect(&mut self) -> Result<(), MqttError<T::Error>>

where T::Error: TransportError,

Attempts to connect to the MQTT broker.

pub async fn publish<'p>( &mut self, _topic: &'p str, _payload: &'p [u8], _qos: QoS, ) -> Result<(), MqttError<T::Error>>

where T::Error: TransportError,

Publishes a message to a topic.

pub async fn poll<'p>( &'p mut self, ) -> Result<Option<MqttEvent<'p>>, MqttError<T::Error>>

where T::Error: TransportError,

Polls the connection for incoming packets and handles keep-alives.

The returned MqttEvent contains references to the client’s internal receive buffer. These references are only valid until the next call to poll.