Struct fluke_maybe_uring::io::ChanWrite

pub struct ChanWrite { /* private fields */ }

Implementations

impl ChanWrite

pub fn new() -> (Receiver<Vec<u8>>, Self)

Trait Implementations

impl WriteOwned for ChanWrite

async fn write<B: IoBuf>(&mut self, buf: B) -> BufResult<usize, B>

Write a single buffer, taking ownership for the duration of the write. Might perform a partial write, see WriteOwned::write_all

async fn write_all<B: IoBuf>(&mut self, buf: B) -> Result<()>

Write a single buffer, re-trying the write if the kernel does a partial write.

async fn writev<B: IoBuf>(&mut self, list: Vec<B>) -> BufResult<usize, Vec<B>>

Write a list of buffers, taking ownership for the duration of the write. Might perform a partial write, see WriteOwned::writev_all

async fn writev_all<B: IoBuf>(&mut self, list: impl Into<Vec<B>>) -> Result<()>

Write a list of buffers, re-trying the write if the kernel does a partial write.