commonware-glue 2026.9.0

Default constructions that span multiple primitives.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

//! Cancellation of an in-flight resolver request.

use commonware_actor::mailbox::{Policy, Sender};

/// Sends its message on drop, unless [`Guard::disarm`] ran first.
pub(super) struct Guard<T: Policy> {
    sender: Sender<T>,
    cancel: Option<T>,
}

impl<T: Policy> Guard<T> {
    pub(super) const fn new(sender: Sender<T>, cancel: T) -> Self {
        Self {
            sender,
            cancel: Some(cancel),
        }
    }

    /// Suppresses the drop-time cancel; call once the fetch has completed.
    pub(super) fn disarm(&mut self) {
        self.cancel = None;
    }
}

impl<T: Policy> Drop for Guard<T> {
    fn drop(&mut self) {
        let Some(cancel) = self.cancel.take() else {
            return;
        };
        let _ = self.sender.enqueue(cancel);
    }
}