Struct Connection

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

MQTT connection. Maintains all the necessary state

Fields

eventloop: EventLoop

Implementations

impl Connection

pub 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 EvenLoop, returning an error if all clients/users have closed requests channel.

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

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

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

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