Trait embedded_svc::mqtt::client::Connection

pub trait Connection: Errors {
    type Message<'a>: Message
    where
        Self: 'a;
    fn next(&mut self) -> Option<Result<Event<Self::Message<'_>>, Self::Error>>;
}

Associated Types

type Message<'a>: Message
where
    Self: 'a

Required methods

fn next(&mut self) -> Option<Result<Event<Self::Message<'_>>, Self::Error>>

GATs do not (yet) define a standard streaming iterator, so we have to put the next() method directly in the Connection trait

Implementations on Foreign Types

impl<'b, C> Connection for &'b mut C where
    C: Connection, 

type Message<'a>
where
    Self: 'a = C::Message<'a>

fn next(&mut self) -> Option<Result<Event<Self::Message<'_>>, Self::Error>>

Implementors