Struct pal_async::io_pool::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, Fut>(f: F) -> Fut::Output

where F: FnOnce(IoDriver<T>) -> Fut, Fut: Future + Send, Fut::Output: 'static + Send,

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

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.