Trait iroh_io::AsyncStreamReader

pub trait AsyncStreamReader {
    type ReadFuture<'a>: Future<Output = Result<Bytes>> + 'a
       where Self: 'a;

    // Required method
    fn read(&mut self, len: usize) -> Self::ReadFuture<'_>;
}

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

Required Associated Types

type ReadFuture<'a>: Future<Output = Result<Bytes>> + 'a where Self: 'a

Future returned by read

Required Methods

fn read(&mut self, len: usize) -> Self::ReadFuture<'_>

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

returns an empty buffer to indicate EOF.

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl AsyncStreamReader for Bytes

type ReadFuture<'a> = Ready<Result<Bytes, Error>>

fn read(&mut self, len: usize) -> Self::ReadFuture<'_>

impl<T: AsyncStreamReader> AsyncStreamReader for &mut T

type ReadFuture<'a> = <T as AsyncStreamReader>::ReadFuture<'a> where Self: 'a

fn read(&mut self, len: usize) -> Self::ReadFuture<'_>

Implementors

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

type ReadFuture<'a> = Pin<Box<dyn Future<Output = Result<Bytes, Error>> + 'a>> where Self: 'a

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

type ReadFuture<'a> = AggregateSizeAndStats<'a, <W as AsyncStreamReader>::ReadFuture<'a>> where Self: 'a