Struct mqttrust_core::Client

pub struct Client<'a, 'b, const T: usize, const P: usize, const L: usize> { /* fields omitted */ }

MQTT Client

This client is meerly a convenience wrapper around a heapless::spsc::Producer, making it easier to send certain MQTT packet types, and maintaining a common reference to a client id. Also it implements the Mqtt trait.

Lifetimes:

• ’a: The lifetime of the queue exhanging packets between the client and the event loop. This must have the same lifetime as the corresponding Consumer. Usually ’static.
• ’b: The lifetime of client id str

Generics:

• L: The length of the queue, exhanging packets between the client and the event loop. Length in number of request packets

Implementations

impl<'a, 'b, const T: usize, const P: usize, const L: usize> Client<'a, 'b, T, P, L>

pub fn new(
    producer: Producer<'a, OwnedRequest<T, P>, L>,
    client_id: &'b str
) -> Self

Trait Implementations

impl<'a, 'b, 'c, const T: usize, const P: usize, const L: usize> Mqtt for Client<'a, 'b, T, P, L>

fn client_id(&self) -> &str

fn send(&self, request: Request<'_>) -> Result<(), MqttError>

fn publish(
    &self,
    topic_name: &str,
    payload: &[u8],
    qos: QoS
) -> Result<(), MqttError>

fn subscribe(&self, topic: SubscribeTopic) -> Result<(), MqttError>

fn subscribe_many(
    &self,
    topics: Vec<SubscribeTopic, 5_usize>
) -> Result<(), MqttError>

fn unsubscribe(&self, topic: String<256_usize>) -> Result<(), MqttError>

fn unsubscribe_many(
    &self,
    topics: Vec<String<256_usize>, 5_usize>
) -> Result<(), MqttError>