Struct LeaseHandoff 

pub struct LeaseHandoff { /* private fields */ }

One delivery’s lease: armed on the fences before the push, recorded at the transport’s accept point, settled on the gate either way.

Dropping an unaccepted handoff (the push failed, the candidate was skipped) settles the gate without recording, so a completion that can never come is never waited for and a later candidate arms its own.

Implementations

impl LeaseHandoff

pub fn key(&self) -> &LeaseKey

The attempt this handoff leases.

pub fn token(&self) -> &CompletionToken

The completion token the lease gate is armed under.

impl LeaseHandoff

pub fn arm( seam: LeaseRecorderSeam, key: LeaseKey, worker: WorkerAttribution, fences: CompletionFences, token: CompletionToken, lease: LeaseSignal, ) -> Result<Self, ServerError>

Arm the fences’ lease gate for token and hold the lease to record.

lease is fired at the same instant the lease is RECORDED, so the engine’s authored per-attempt bound and the durable ActivityLeased event share one anchor by construction. A caller with no per-attempt timer above it — the outbox push leg, whose dispatches are not driven by the engine’s retry loop — passes LeaseSignal::none, which is a statement that nothing is timing this attempt rather than a value standing in for one.

Errors

Returns lock poison from the fences.

pub fn accepted_blocking(&self, handle: Option<&Handle>)

Record the lease from a thread that cannot await, then settle the gate.

Trait Implementations

impl Debug for LeaseHandoff

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

Formats the value using the given formatter.

impl DeliveryAccepted for LeaseHandoff

fn accepted<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

The worker holds the task.

impl Drop for LeaseHandoff

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.