Struct minimq::Minimq

pub struct Minimq<TcpStack, Clock, const MSG_SIZE: usize, const MSG_COUNT: usize> where
    TcpStack: TcpClientStack,
    Clock: Clock,  {
    pub client: MqttClient<TcpStack, Clock, MSG_SIZE, MSG_COUNT>,
    // some fields omitted
}

The general structure for managing MQTT via Minimq.

Fields

client: MqttClient<TcpStack, Clock, MSG_SIZE, MSG_COUNT>

Implementations

impl<TcpStack: TcpClientStack, Clock: Clock, const MSG_SIZE: usize, const MSG_COUNT: usize> Minimq<TcpStack, Clock, MSG_SIZE, MSG_COUNT>

pub fn new(
    broker: IpAddr,
    client_id: &str,
    network_stack: TcpStack,
    clock: Clock
) -> Result<Self, Error<TcpStack::Error>>

Construct a new MQTT interface.

Args

• broker - The IP address of the broker to connect to.
• client_id The client ID to use for communicating with the broker. If empty, rely on the broker to automatically assign a client ID.
• network_stack - The network stack to use for communication.
• clock - The clock to use for managing MQTT state timing.

Returns

A Minimq object that can be used for publishing messages, subscribing to topics, and managing the MQTT state.

pub fn poll<F>(&mut self, f: F) -> Result<(), Error<TcpStack::Error>> where
    for<'a> F: FnMut(&mut MqttClient<TcpStack, Clock, MSG_SIZE, MSG_COUNT>, &'a str, &[u8], &[Property<'a>]), 

Check the MQTT interface for available messages.

Args

• f - A closure to process any received messages. The closure should accept the client, topic, message, and list of proprties (in that order).