Trait AsyncStreamReader 

pub trait AsyncStreamReader {
    // Required methods
    fn read_bytes(&mut self, len: usize) -> impl Future<Output = Result<Bytes>>;
    fn read<const L: usize>(&mut self) -> impl Future<Output = Result<[u8; L]>>;

    // Provided methods
    fn read_bytes_exact(
        &mut self,
        len: usize,
    ) -> impl Future<Output = Result<Bytes>> { ... }
    fn read_exact<const L: usize>(
        &mut self,
    ) -> impl Future<Output = Result<[u8; L]>> { ... }
}

A non seekable reader, e.g. a network socket.

Required Methods

fn read_bytes(&mut self, len: usize) -> impl Future<Output = Result<Bytes>>

Read at most len bytes. To read to the end, pass u64::MAX.

returns an empty buffer to indicate EOF.

fn read<const L: usize>(&mut self) -> impl Future<Output = Result<[u8; L]>>

Read a fixed size buffer.

If there are less than L bytes available, an io::ErrorKind::UnexpectedEof error is returned.

Provided Methods

fn read_bytes_exact( &mut self, len: usize, ) -> impl Future<Output = Result<Bytes>>

Variant of read_bytes that returns an error if less than len bytes are read.

fn read_exact<const L: usize>( &mut self, ) -> impl Future<Output = Result<[u8; L]>>

Variant of read that returns an error if less than L bytes are read.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementations on Foreign Types

impl AsyncStreamReader for &[u8]

async fn read_bytes(&mut self, len: usize) -> Result<Bytes>

async fn read<const L: usize>(&mut self) -> Result<[u8; L]>

impl AsyncStreamReader for Bytes

async fn read_bytes(&mut self, len: usize) -> Result<Bytes>

async fn read<const L: usize>(&mut self) -> Result<[u8; L]>

impl AsyncStreamReader for BytesMut

async fn read_bytes(&mut self, len: usize) -> Result<Bytes>

async fn read<const L: usize>(&mut self) -> Result<[u8; L]>

impl<T: AsyncSliceReader> AsyncStreamReader for Cursor<T>

async fn read_bytes(&mut self, len: usize) -> Result<Bytes>

async fn read<const L: usize>(&mut self) -> Result<[u8; L]>

impl<T: AsyncStreamReader> AsyncStreamReader for &mut T

async fn read_bytes(&mut self, len: usize) -> Result<Bytes>

async fn read<const L: usize>(&mut self) -> Result<[u8; L]>

Implementors

impl<T: AsyncRead + Unpin> AsyncStreamReader for TokioStreamReader<T>

impl<W: AsyncStreamReader> AsyncStreamReader for TrackingStreamReader<W>