Trait completion::io::AsyncReadWith

pub trait AsyncReadWith<'a> {
    type ReadFuture: CompletionFuture;
    pub fn read(&'a mut self, buf: ReadBufMut<'a>) -> Self::ReadFuture;
}

This is supported on crate feature std only.

Read bytes from a source asynchronously with a specific lifetime.

Associated Types

type ReadFuture: CompletionFuture

The future that reads from the source.

Loading content...

Required methods

pub fn read(&'a mut self, buf: ReadBufMut<'a>) -> Self::ReadFuture

Pull some bytes from this source into the specified buffer.

If this reads 0 bytes of data, either the buffer was 0 bytes in length or the stream has reached EOF.

Loading content...

Implementations on Foreign Types

impl<'a, 's> AsyncReadWith<'a> for &'s [u8]

type ReadFuture = ReadSlice<'a, 's>

pub fn read(
    &'a mut self,
    buf: ReadBufMut<'a>
) -> <&'s [u8] as AsyncReadWith<'a>>::ReadFuture

impl<'a, T> AsyncReadWith<'a> for Cursor<T> where
    T: AsRef<[u8]>, 

type ReadFuture = ReadCursor<'a, T>

pub fn read(
    &'a mut self,
    buf: ReadBufMut<'a>
) -> <Cursor<T> as AsyncReadWith<'a>>::ReadFuture

impl<'a> AsyncReadWith<'a> for Empty

type ReadFuture = Ready<Result<(), Error>>

pub fn read(
    &'a mut self,
    _buf: ReadBufMut<'a>
) -> <Empty as AsyncReadWith<'a>>::ReadFuture

impl<'a, '_, R> AsyncReadWith<'a> for &'_ mut R where
    R: AsyncReadWith<'a> + ?Sized, 

type ReadFuture = <R as AsyncReadWith<'a>>::ReadFuture

pub fn read(
    &'a mut self,
    buf: ReadBufMut<'a>
) -> <&'_ mut R as AsyncReadWith<'a>>::ReadFuture

impl<'a, R> AsyncReadWith<'a> for Box<R, Global> where
    R: AsyncReadWith<'a> + ?Sized, 

type ReadFuture = <R as AsyncReadWith<'a>>::ReadFuture

pub fn read(
    &'a mut self,
    buf: ReadBufMut<'a>
) -> <Box<R, Global> as AsyncReadWith<'a>>::ReadFuture

impl<'a> AsyncReadWith<'a> for Repeat

type ReadFuture = ReadRepeat<'a>

pub fn read(
    &'a mut self,
    buf: ReadBufMut<'a>
) -> <Repeat as AsyncReadWith<'a>>::ReadFuture

Loading content...

Implementors

impl<'a, R: AsyncBufRead> AsyncReadWith<'a> for TakeUntil<R>

type ReadFuture = ReadTakeUntil<'a, R>

fn read(&'a mut self, buf: ReadBufMut<'a>) -> Self::ReadFuture

impl<'a, R: AsyncRead> AsyncReadWith<'a> for BufReader<R>

type ReadFuture = ReadBufReader<'a, R>

fn read(&'a mut self, buf: ReadBufMut<'a>) -> Self::ReadFuture

impl<'a, T: AsyncRead> AsyncReadWith<'a> for Take<T>

type ReadFuture = ReadTake<'a, T>

fn read(&'a mut self, buf: ReadBufMut<'a>) -> Self::ReadFuture

impl<'a, T: AsyncRead, U: AsyncRead + 'static> AsyncReadWith<'a> for Chain<T, U>

type ReadFuture = ReadChain<'a, T, U>

fn read(&'a mut self, buf: ReadBufMut<'a>) -> Self::ReadFuture

impl<'a, W: AsyncReadWith<'a>> AsyncReadWith<'a> for BufWriter<W>

type ReadFuture = W::ReadFuture

fn read(&'a mut self, buf: ReadBufMut<'a>) -> Self::ReadFuture

Loading content...