Module event_loop 

Single-connection event loop.

Structs

EstablishedConnection 🔒

State produced by a successful connect + CONNACK handshake.

InboundAliases 🔒

Inbound topic alias map: resolves aliases in incoming PUBLISH.

LoopState 🔒

Mutable state that persists across reconnection attempts.

OutboundAliases 🔒

Outbound topic alias map: assigns and tracks aliases for outgoing PUBLISH.

PacketIo 🔒

Bundled I/O and state for processing a single incoming packet.

Pending 🔒

Enums

DisconnectReason 🔒

Why a single connection attempt ended.

OwnedRetransmit 🔒

Owned copy of retransmission data, used to bridge the sync for_each_retransmit callback and async packet writing.

Functions

apply_jitter 🔒

build_connect 🔒

dispatch_event 🔒

drain_queued_commands 🔒

establish_connection 🔒

Perform TCP connect, send CONNECT, wait for CONNACK, and retransmit any pending QoS messages when resuming a session.

flush_journal 🔒

Drain pending journal bytes and write them to the journal (if any).

handle_command 🔒

handle_incoming_packet 🔒

owned_retransmit_to_packet 🔒

reset_keep_alive 🔒

resolve_inbound_alias 🔒

Resolve an inbound topic alias, returning the full topic if the alias was used. Updates the alias map as a side effect.

retransmit_pending 🔒

Retransmit all pending QoS 1/2 messages after session resumption.

run

run_connection 🔒

send_disconnect 🔒

send_subscribe 🔒

send_unsubscribe 🔒