Struct Connection 

pub struct Connection {
    pub eventloop: EventLoop,
    /* private fields */
}

MQTT connection. Maintains all the necessary state

Fields

eventloop: EventLoop

Implementations

impl Connection

pub const fn iter(&mut self) -> Iter<'_>

Returns an iterator over this connection. Iterating over this is all that’s necessary to make connection progress and maintain a robust connection. Just continuing to loop will reconnect NOTE Don’t block this while iterating

pub fn recv(&mut self) -> Result<Result<Event, ConnectionError>, RecvError>

Attempt to fetch an incoming Event on the EventLoop, returning an error if all clients/users have closed requests channel.

Errors

Returns RecvError if all request senders have been dropped.

pub fn try_recv( &mut self, ) -> Result<Result<Event, ConnectionError>, TryRecvError>

Attempt to fetch an incoming Event on the EventLoop, returning an error if none immediately present or all clients/users have closed requests channel.

Errors

Returns TryRecvError::Empty if no event is immediately ready, or TryRecvError::Disconnected if all request senders have been dropped.

pub fn recv_timeout( &mut self, duration: Duration, ) -> Result<Result<Event, ConnectionError>, RecvTimeoutError>

Attempt to fetch an incoming Event on the EventLoop, returning an error if all clients/users have closed requests channel or the timeout has expired.

Errors

Returns RecvTimeoutError::Timeout if no event arrives before duration, or RecvTimeoutError::Disconnected if all request senders have been dropped.