We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b664fd6 commit b6d447dCopy full SHA for b6d447d
rumqttc/src/lib.rs
@@ -225,6 +225,7 @@ impl From<Unsubscribe> for Request {
225
}
226
227
228
+/// Packet Identifier with which Publish/Subscribe/Unsubscribe packets are identified while inflight.
229
pub type Pkid = u16;
230
231
#[derive(Debug, thiserror::Error)]
@@ -235,6 +236,9 @@ pub enum PromiseError {
235
236
Rejected { reason: String },
237
238
239
+/// Resolves with [`Pkid`] used against packet when:
240
+/// 1. Packet is acknowldged by the broker, e.g. QoS 1/2 Publish, Subscribe and Unsubscribe
241
+/// 2. QoS 0 packet finishes processing in the [`EventLoop`]
242
pub struct AckPromise {
243
rx: oneshot::Receiver<Result<Pkid, PromiseError>>,
244
0 commit comments