Enum AckCompletion 

pub enum AckCompletion {
    User(Sender<Result<Vec<ReasonCode>, Error>>),
    Internal,
}

Where an in-flight SUBSCRIBE/UNSUBSCRIBE’s outcome goes once the SUBACK/UNSUBACK arrives (or the operation is dropped or superseded).

Variants

User(Sender<Result<Vec<ReasonCode>, Error>>)

A user command is waiting on this operation.

Internal

An internally replayed operation (e.g. re-subscribing after the broker reports no session) that no user future is watching. Tracked the same as User for ack-timeout purposes, just resolved into nothing on completion.

Implementations

impl AckCompletion

pub fn resolve(self, result: Result<Vec<ReasonCode>, Error>)

Resolves a User completion; a no-op for Internal.