Struct ProbeInFlight 

struct ProbeInFlight {
    inner: Arc<BridgeInner>,
    session_id: String,
    taken_at: Instant,
}

Holds a seat’s probe mark while its probe is out, and releases it however the probe ends: an answer, an error, a timeout, or a dispatch that never reached a client at all.

A guard rather than a release at each exit, because the exits multiply - the timeout returns early, and the closure is dropped uncalled when no client is bound.

It releases only the mark it took: one reclaimed by a later ask belongs to that ask’s probe, and a late drop must not clear the live mark.

Fields

inner: Arc<BridgeInner>

session_id: String

taken_at: Instant

Trait Implementations

impl Drop for ProbeInFlight

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.