Struct MqttEventLoop

pub struct MqttEventLoop {
    pub options: MqttOptions,
    pub state: MqttState,
    pub requests: Box<dyn Requests>,
    /* private fields */
}

Complete state of the eventloop

Fields

options: MqttOptions

Options of the current mqtt connection

state: MqttState

Current state of the connection

requests: Box<dyn Requests>

Request stream

Implementations

impl MqttEventLoop

pub async fn connect<'eventloop>( &'eventloop mut self, ) -> Result<impl Stream<Item = Notification> + 'eventloop, EventLoopError>

Connects to the broker and returns a stream that does everything MQTT. This stream internally processes requests from the request stream provided to the eventloop while also consuming byte stream from the network and yielding mqtt packets as the output of the stream