Struct pseudo_async_io::PseudoAsyncIoPair

pub struct PseudoAsyncIoPair<R: Read, W: Write> {
    pub reader: R,
    pub writer: W,
}

Fields

reader: R

writer: W

Methods

impl<R: Read, W: Write> PseudoAsyncIoPair<R, W>

pub fn new(r: R, w: W) -> PseudoAsyncIoPair<R, W>

Trait Implementations

impl<R: Read, W: Write> AsyncRead for PseudoAsyncIoPair<R, W>

fn poll_read(&mut self, _: &Waker, b: &mut [u8]) -> Poll<Result<usize, Error>>

Attempt to read from the AsyncRead into buf.

unsafe fn initializer(&self) -> Initializer

Determines if this AsyncReader can work with buffers of uninitialized memory.

fn poll_vectored_read(
    &mut self,
    waker: &Waker,
    vec: &mut [&mut IoVec]
) -> Poll<Result<usize, Error>>

Attempt to read from the AsyncRead into vec using vectored IO operations.

impl<R: Read, W: Write> AsyncWrite for PseudoAsyncIoPair<R, W>

fn poll_write(&mut self, _: &Waker, b: &[u8]) -> Poll<Result<usize, Error>>

Attempt to write bytes from buf into the object.

fn poll_flush(&mut self, _: &Waker) -> Poll<Result<(), Error>>

Attempt to flush the object, ensuring that any buffered data reach their destination.

fn poll_close(&mut self, _: &Waker) -> Poll<Result<(), Error>>

Attempt to close the object.

fn poll_vectored_write(
    &mut self,
    waker: &Waker,
    vec: &[&IoVec]
) -> Poll<Result<usize, Error>>

Attempt to write bytes from vec into the object using vectored IO operations.