Struct BlockingDrainLease 

pub struct BlockingDrainLease { /* private fields */ }

A bounded authority for I/O required by an operation already accepted by a service scope.

A lease is created while its scope is open. It may then be used during that scope’s shutdown, but only until its original deadline or an earlier shutdown deadline installed on that scope, and only for its reserved number of submissions. It is deliberately not cloneable: moving it preserves one shared, non-expandable allowance.

Implementations

impl BlockingDrainLease

pub fn spawn_io<F, R>( &self, name: impl Into<Arc<str>>, operation: F, ) -> impl Future<Output = RuntimeResult<R>> + Send + '_

where F: FnOnce() -> R + Send + 'static, R: Send + 'static,

Runs one short I/O operation under this lease.

The existing lane capacity and deadline policy still apply. A running closure retains its execution permit until it exits. This does not reopen the scope’s ordinary admission.

pub fn spawn_io_until<F, R>( &self, name: impl Into<Arc<str>>, deadline: ShutdownDeadline, operation: F, ) -> impl Future<Output = RuntimeResult<R>> + Send + '_

where F: FnOnce() -> R + Send + 'static, R: Send + 'static,

Runs one short I/O operation without extending this lease’s deadline.

pub fn remaining_operations(&self) -> usize

Returns the number of submissions that this lease can still admit.

Trait Implementations

impl Debug for BlockingDrainLease

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

Formats the value using the given formatter.