Struct Reader

pub struct Reader<T> { /* private fields */ }

Available on crate feature io only.

Implementations

impl<T> Reader<T>

pub const fn new(stream: T) -> Self

Trait Implementations

impl<T, E> AsyncRead for Reader<T>

where T: Stream<Item = Result<u8, E>> + Unpin,

type Error = E

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut [u8], ) -> Poll<Result<usize, Self::Error>>

Attempt to read from the AsyncRead into buf. On success, returns Poll::Ready(Ok(num_bytes_read)). If no data is available for reading, this method returns Poll::Pending and arranges for the current task to be woken.

fn read<'a>(&'a mut self, buf: &'a mut [u8]) -> Read<'a, Self>

where Self: Unpin,

Tries to read some bytes directly into the given buf in asynchronous manner, returning a future type.