[−][src]Struct rumq_client::MqttEventLoop

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

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

Methods

impl MqttEventLoop[src]

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

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

Auto Trait Implementations

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized, [src]

impl<T> Borrow<T> for T where
    T: ?Sized, [src]

impl<T> BorrowMut<T> for T where
    T: ?Sized, [src]

impl<T> From<T> for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, [src]

impl<T, U> TryFrom<U> for T where
    U: Into<T>, [src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, [src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.