Struct LoopState 

struct LoopState<'a> {
    client: &'a mut Client<JournaledSession>,
    cmd_rx: &'a mut Receiver<Command>,
    cmds_open: &'a mut bool,
    shutdown_rx: &'a mut Receiver<()>,
    msg_tx: &'a Sender<Message>,
    store: &'a mut Persistence,
    queued_commands: &'a mut VecDeque<Command>,
    offline_pending: &'a mut HashMap<PacketId, PendingPublish>,
    offline_acks: &'a mut HashMap<PacketId, PendingAck>,
    queued_waiting: &'a mut Vec<Sender<Result<(), Error>>>,
    status_tx: &'a Sender<ConnectionStatus>,
}

Mutable state that persists across reconnection attempts.

Fields

client: &'a mut Client<JournaledSession>

cmd_rx: &'a mut Receiver<Command>

cmds_open: &'a mut bool

false once every client handle is dropped and cmd_rx is drained; the selects then stop polling the closed channel.

shutdown_rx: &'a mut Receiver<()>

msg_tx: &'a Sender<Message>

store: &'a mut Persistence

queued_commands: &'a mut VecDeque<Command>

offline_pending: &'a mut HashMap<PacketId, PendingPublish>

Completion futures for QoS >= 1 publishes accepted while offline, adopted into this connection’s Pending once it is established.

offline_acks: &'a mut HashMap<PacketId, PendingAck>

Completion futures for SUBSCRIBE/UNSUBSCRIBE accepted while offline or left in flight across a reconnect, adopted into this connection’s Pending once it is established.

queued_waiting: &'a mut Vec<Sender<Result<(), Error>>>

queued() futures awaiting the persist that covers their session mutation; resolved by persist_and_ack, carried across connections.

status_tx: &'a Sender<ConnectionStatus>