Struct PollContext 

pub(crate) struct PollContext {
    pub(crate) client: AsyncClient,
    pub(crate) event_loop: EventLoop,
    pub(crate) close_rx: Receiver<()>,
    pub(crate) mqtt_ctx: Arc<Mutex<MqttContext>>,
    pub(crate) min_reconnect_delay: Duration,
    pub(crate) max_reconnect_delay: Duration,
    pub(crate) reconnect_delay: Duration,
}

It is a struct that holds the necessary components for polling the MQTT broker.

Fields

client: AsyncClient

event_loop: EventLoop

close_rx: Receiver<()>

mqtt_ctx: Arc<Mutex<MqttContext>>

min_reconnect_delay: Duration

max_reconnect_delay: Duration

reconnect_delay: Duration

Current delay between reconnection attempts.

Duration::ZERO means that the client is currently connected.

Implementations

impl PollContext

pub(crate) fn new( client: AsyncClient, event_loop: EventLoop, close_rx: Receiver<()>, mqtt_ctx: Arc<Mutex<MqttContext>>, min_reconnect_delay: Duration, max_reconnect_delay: Duration, ) -> Self