Struct mqttrust_core::EventLoop

pub struct EventLoop<'a, 'b, S, O, const T: usize, const P: usize, const L: usize> where
    O: Clock,  {
    pub state: MqttState<Instant<O>, T, P>,
    pub last_outgoing_timer: O,
    pub options: MqttOptions<'b>,
    pub requests: Consumer<'a, OwnedRequest<T, P>, L>,
    // some fields omitted
}

Fields

state: MqttState<Instant<O>, T, P>

Current state of the connection

last_outgoing_timer: O

Last outgoing packet time

options: MqttOptions<'b>

Options of the current mqtt connection

requests: Consumer<'a, OwnedRequest<T, P>, L>

Request stream

Implementations

impl<'a, 'b, S, O, const T: usize, const P: usize, const L: usize> EventLoop<'a, 'b, S, O, T, P, L> where
    O: Clock, 

pub fn new(
    requests: Consumer<'a, OwnedRequest<T, P>, L>,
    outgoing_timer: O,
    options: MqttOptions<'b>
) -> Self

pub fn connect<N: Dns + TcpClientStack<TcpSocket = S>>(
    &mut self,
    network: &mut N
) -> Result<bool, EventError>

pub fn yield_event<N: TcpClientStack<TcpSocket = S>>(
    &mut self,
    network: &mut N
) -> Result<Notification, Infallible>

Yields notification from events. All the error raised while processing event is reported as an Ok value of Notification::Abort.

pub fn disconnect<N: TcpClientStack<TcpSocket = S>>(&mut self, network: &mut N)