Struct Reader 

pub struct Reader {
    pub inner: Mode,
    pub op: Op,
}

Fields

inner: Mode

op: Op

Implementations

impl Reader

pub fn new(inner: impl Into<Mode>) -> Self

pub fn with_buf( inner: ReadableStreamByobReader, internal_buf: ArrayBuffer, ) -> Self

pub async fn read_into(&mut self, buf: &mut [u8]) -> Result<usize, ReadError>

Read from the stream into the given buffer, returning the number of bytes read.

Returns Ok(0) when the stream is closed and has no more data.

Consumes the leftovers of the chunks that did not fit into the buffers of the previous reads, and resolves the reads left pending by a dropped tokio::io::AsyncRead::poll_read.

Trait Implementations

impl AsyncRead for Reader

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut ReadBuf<'_>, ) -> Poll<Result<()>>

Attempts to read from the AsyncRead into buf.

impl Debug for Reader

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

Formats the value using the given formatter.