Struct TokioStreamReader 

pub struct TokioStreamReader<T>(pub T);

Utility to convert a tokio::io::AsyncRead into an AsyncStreamReader.

Tuple Fields

0: T

Implementations

impl<T> TokioStreamReader<T>

pub fn new(inner: T) -> Self

Create a new TokioStreamReader from an inner reader

pub fn into_inner(self) -> T

Return the inner reader

Trait Implementations

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

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

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

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

Read a fixed size buffer.

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.

impl<T: Clone> Clone for TokioStreamReader<T>

fn clone(&self) -> TokioStreamReader<T>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug> Debug for TokioStreamReader<T>

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

Formats the value using the given formatter.