Struct Lio 

pub struct Lio { /* private fields */ }

Implementations

impl Lio

pub fn new(cap: usize) -> Result<Self>

Creates a new Lio driver with the default backend and specified capacity.

Arguments

• cap - The maximum number of concurrent operations

Example

use lio::Lio;

let mut lio = Lio::new(1024).unwrap();

pub fn new_with_backend<D>(backend: D, cap: usize) -> Result<Self>

where D: IoBackend + 'static,

Creates a new Lio driver with the specified backend and capacity.

Arguments

• backend - The I/O backend implementation (e.g., io_uring, epoll/kqueue)
• cap - The maximum number of concurrent operations

Example

use lio::Lio;
use lio::backends::pollingv2::Poller;

let mut lio = Lio::new_with_backend(Poller::new(), 1024).unwrap();

pub fn try_run(&self) -> Result<usize>

Non-blocking poll for completed operations.

Returns immediately, processing any completions that are ready.

pub fn run(&self) -> Result<usize>

Block until at least one operation completes.

pub fn run_timeout(&self, timeout: Duration) -> Result<usize>

Run the event loop with a timeout.

Waits for at least one operation to complete or until the timeout expires, whichever comes first. Returns Ok(true) if completions were processed, Ok(false) if the timeout expired with no completions.

Trait Implementations

impl Clone for Lio

fn clone(&self) -> Lio

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.