Function resubscribe_confirmed
pub(super) fn resubscribe_confirmed(
client: &mut Client<JournaledSession>,
pending: &mut Pending,
)Expand description
Re-issues every confirmed subscription as a fresh SUBSCRIBE after a
Session Present = 0 CONNACK so the broker re-establishes it. In-flight
SUBSCRIBEs are not touched here: they are re-armed on connect and re-sent
by the next session pump. Because each filter is a single entry, a filter
is re-issued by exactly one path, so none goes out twice. A replay carries
no user future, but it still gets a pending.acks entry tagged
AckCompletion::Internal so the pump arms an ack-timeout deadline for
it like any other in-flight SUBSCRIBE.