Struct BlockingWork 

pub struct BlockingWork { /* private fields */ }

Embedders must finish draining before releasing execution resources. Dropping a waiter leaves its actual blocking worker registered here.

Implementations

impl BlockingWork

pub async fn spawn<T: Send + 'static>( &mut self, work: impl FnOnce() -> T + Send + 'static, ) -> Result<T, BlockingWorkError>

Run a synchronous closure on an owned native thread and await its result. At most 512 such threads are admitted across executions, independently of the Tokio runtime’s blocking-pool configuration. Cancellation leaves the join registered until another finish call drains it.

pub async fn finish(&mut self) -> Result<(), BlockingWorkDrainError>

Drain all owned work, even when one worker fails. Cancelling this future retains unfinished joins and failures already observed for a later call.

Trait Implementations

impl Default for BlockingWork

fn default() -> Self

Returns the “default value” for a type.