Module pending 

Tracking and resolution of in-flight operation futures.

Structs

Pending 🔒

Functions

ack_queued 🔒

Resolves the optional queue-acknowledgement channel immediately. Only for operations with no durable state (QoS 0); anything stored in the session parks via park_queued instead.

disarm 🔒

Drops packet_id’s entry from order, if it has one.

dispatch_ack 🔒

Dispatches a non-message client event (acknowledgements). Returns true when the event freed a send-quota slot so the caller can pump the session.

fail_op 🔒

Resolves an operation’s futures with an error, leaving the connection intact. err is any error source convertible into Error; it is materialised separately for each channel because Error is not Clone.

fail_superseded_acks 🔒

Fails every parked SUBSCRIBE/UNSUBSCRIBE completion whose packet id no longer owns any filter entry. A later request for the same filter superseded it in the core (one filter is one entry), so the orphaned packet id is never put on the wire and its SUBACK/UNSUBACK can never arrive; the future would otherwise hang. Mirrors the broker replacing the prior subscription with the newer one.

park_queued 🔒

Parks the optional queue-acknowledgement channel until the next successful persist, so queued() reflects real durability.

rearm 🔒

Arms (or re-arms) deadline for packet_id, keeping order in sync so the earliest deadline is always its first().

reject_offline 🔒

Rejects an offline operation because the queue is full.

Type Aliases

QueuedWaiters 🔒

queued() futures whose session mutation has not been persisted yet; resolved by the next successful persist.