Struct MqttEventLoop 

pub struct MqttEventLoop<'l, M: RawMutex, const B: usize> { /* private fields */ }

The main eventloop of the MQTT client

This struct holds all state an buffers for the mqtt client

Implementations

impl<M: RawMutex, const B: usize> MqttEventLoop<'static, M, B>

pub fn new(config: ClientConfig) -> Self

Create a new event loop

impl<'l, M: RawMutex, const B: usize> MqttEventLoop<'l, M, B>

pub fn new_with_last_will(config: ClientConfig, last_will: LastWill<'l>) -> Self

pub fn client<'a>(&'a self) -> MqttClient<'a, M>

Create a client for the event loop. The Client can be used to publish and receive messages, …

There can be multiple MqttClient for one MqttEventLoop. But concurrent receives from multiple clients result in not all clients to receive all publishes

pub async fn run<N: NetworkConnection>( &self, connection: Pin<&mut N>, ) -> Result<(), MqttError>