Struct IoPool

pub struct IoPool<T> { /* private fields */ }

An single-threaded task pool backed by IO backend T.

Implementations

impl<T: IoBackend + Default> IoPool<T>

pub fn new() -> Self

Creates a new task pool.

pub fn run_with<F, R>(f: F) -> R

where F: AsyncFnOnce(IoDriver<T>) -> R,

Creates and runs a task pool, seeding it with an initial future f(driver), until all tasks have completed.

pub fn spawn_on_thread(name: impl Into<String>) -> (JoinHandle<()>, IoDriver<T>)

where T: 'static,

Creates a new pool and runs it on a newly spawned thread with the given name. Returns the thread handle and the pool’s driver.

impl<T: IoBackend> IoPool<T>

pub fn driver(&self) -> IoDriver<T>

Returns the IO driver.

pub fn run_until<Fut: Future>(&mut self, f: Fut) -> Fut::Output

Runs f and the task pool until f completes.

pub fn run(self)

Runs the task pool until all tasks are completed.

Trait Implementations

impl<T: Debug> Debug for IoPool<T>

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

Formats the value using the given formatter.