Struct InFlightGauge 

pub struct InFlightGauge { /* private fields */ }

Context-global in-flight gauge (drainclaim): the accepted-not-completed exchange counter plus a zero-transition notification.

Counting is owned by InFlightClaim RAII (attach increments, drop decrements) — inc/dec are crate-private so no cross-crate code can skew the count outside the claim lifecycle. Observers read the live count via InFlightGauge::total and await quiescence via InFlightGauge::idle: the last release (1→0) fires notify_waiters(), waking every waiter registered before the release (register-before-check: pin the notified() future and enable() it, then read state). The sync-callable notify is what makes Drop a completion signal for notification-based settle.

Implementations

impl InFlightGauge

pub fn new() -> Self

Create a gauge with a zero count.

pub fn total(&self) -> u64

Read the live in-flight count (Acquire load; pairs with the Release decrement so a woken waiter observes the zero).

pub fn idle(&self) -> &Notify

Notification slot resolved on the last release (1→0). Waiters must register before checking the count (pin + enable()); notifications are not stored.

Trait Implementations

impl Default for InFlightGauge

fn default() -> Self

Returns the “default value” for a type.