Struct mio_aio::LioCb

pub struct LioCb<'a> { /* private fields */ }

A collection of multiple asynchronous I/O operations

Implementations

impl<'a> LioCb<'a>

pub fn submit(&mut self) -> Result<(), LioError>

Submit an LioCb to the aio(4) subsystem.

If the return value is LioError::EAGAIN, then no operations were enqueued due to system resource limitations. The application should free up resources and try again. If the return value is LioError::EINCOMPLETE, then some operations were enqueued, but others were not, due to system resource limitations. The application should wait for notification that the enqueued operations are complete, then resubmit the others with resubmit. If the return value is LioError::EIO, then some operations have failed to enqueue, and cannot be resubmitted. The application should wait for notification that the enqueued operations are complete, then examine the result of each operation to determine the problem.

pub fn resubmit(&mut self) -> Result<(), LioError>

Resubmit an LioCb if it is incomplete.

If submit returns LioError::EINCOMPLETE, then some operations may not have been submitted. This method will collect status for any completed operations, then resubmit the others.

lio_listio

pub fn into_results<F, R>(self, callback: F) -> R where
    F: FnOnce(Box<dyn Iterator<Item = LioResult> + 'a>) -> R, 

Consume an LioCb and collect its operations’ results.

An iterator over all operations’ results will be supplied to the callback function.

Trait Implementations

impl<'a> Debug for LioCb<'a>

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

Formats the value using the given formatter.

impl<'a> Source for LioCb<'a>

fn register(
    &mut self,
    registry: &Registry,
    token: Token,
    interests: Interest
) -> Result<()>

Register self with the given Registry instance.

fn reregister(
    &mut self,
    registry: &Registry,
    token: Token,
    interests: Interest
) -> Result<()>

Re-register self with the given Registry instance.

fn deregister(&mut self, _registry: &Registry) -> Result<()>

Deregister self from the given Registry instance.