Struct ChannelEventLoop 

pub struct ChannelEventLoop { /* private fields */ }

An EventLoop implementation that uses channels

Examples

See ChannelBroker

Implementations

impl ChannelEventLoop

pub fn new() -> (Self, ChannelClient, ChannelBroker)

Creates a new event loop along with the corresponding client and broker.

Trait Implementations

impl EventLoop for ChannelEventLoop

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