Struct TurnLease 

pub struct TurnLease { /* private fields */ }

One talk’s cross-process turn slot, released on drop (success, error, panic or a dropped handler future alike). Release only removes the file while it still carries this lease’s token, so a guard that outlived its own expiry cannot delete the lease of whoever took over.

Implementations

impl TurnLease

pub fn beat(&self) -> Result<bool>

Renew the lease. Ok(false) means it was taken over or removed, so this turn no longer owns the slot; Err is a transient failure (the lock stayed busy, a write failed) and the next beat tries again.

pub async fn beating<T>(&self, fut: impl Future<Output = T>) -> Result<T>

Run fut while renewing this lease every TURN_BEAT. A transient beat failure is logged and the turn goes on; a lost lease drops fut (the turn stops) and is an error, since somebody else may now be running the same conversation.

Trait Implementations

impl Debug for TurnLease

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for TurnLease

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.