Struct EventLoop 

pub struct EventLoop { /* private fields */ }

An srad_client::EventLoop implementation using rumqttc

Implementations

impl EventLoop

pub fn new(options: MqttOptions, cap: usize) -> (Self, Client)

Create a new Eventloop.

options are the mqtt options to create the rumqtt client with. Some options will be overwritten to ensure Sparkplug compliance.

cap specifies the capacity of the bounded async channel for the client handle.

Trait Implementations

impl EventLoop for EventLoop

fn poll<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Event> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Poll the EventLoop for an event Continuing to poll will reconnect if there is a disconnection. NOTE Don’t block this while iterating

fn set_last_will(&mut self, will: LastWill)

Set the last will to be used on the next connection