Trait iroh_io::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]>>;
}

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.

Object Safety

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>