tollgate-client 0.30.2

Instance-side quota runtime: background lease refill into the admission layer's LeaseSlot, and a bounded, batched, shed-on-overflow usage writer.
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

//! A task owns the last value observers retain after its health channel closes.
use tokio::sync::watch;

/// Construct before spawning, and move into the future. Unlike a statement
/// after `run().await`, Drop also runs on unwind, cancellation and destruction
/// before the first poll. There is one publisher; callers only borrow it.
pub(crate) struct TaskHealth(watch::Sender<bool>);

impl TaskHealth {
    pub(crate) fn channel(initial: bool) -> (Self, watch::Receiver<bool>) {
        let (sender, receiver) = watch::channel(initial);
        (Self(sender), receiver)
    }

    pub(crate) fn sender(&self) -> &watch::Sender<bool> {
        &self.0
    }
}

impl Drop for TaskHealth {
    fn drop(&mut self) {
        // Retain false even if no receivers currently remain. Existing
        // receivers observe this value before closure, including via borrow.
        self.0.send_replace(false);
    }
}