Struct FuturesAsyncReader

pub struct FuturesAsyncReader { /* private fields */ }

FuturesAsyncReader is the adapter of AsyncRead, AsyncBufRead and AsyncSeek generated by Reader::into_futures_async_read.

Users can use this adapter in cases where they need to use AsyncRead related trait. FuturesAsyncReader reuses the same concurrent and chunk settings from Reader.

FuturesAsyncReader also implements Unpin, Send and Sync

Trait Implementations

impl AsyncBufRead for FuturesAsyncReader

fn poll_fill_buf( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<&[u8]>>

Attempt to return the contents of the internal buffer, filling it with more data from the inner reader if it is empty.

fn consume(self: Pin<&mut Self>, amt: usize)

Tells this buffer that amt bytes have been consumed from the buffer, so they should no longer be returned in calls to poll_read.

impl AsyncRead for FuturesAsyncReader

TODO: implement vectored read.

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut [u8], ) -> Poll<Result<usize>>

Attempt to read from the AsyncRead into buf.

fn poll_read_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &mut [IoSliceMut<'_>], ) -> Poll<Result<usize, Error>>

Attempt to read from the AsyncRead into bufs using vectored IO operations.

impl AsyncSeek for FuturesAsyncReader

fn poll_seek( self: Pin<&mut Self>, _: &mut Context<'_>, pos: SeekFrom, ) -> Poll<Result<u64>>

Attempt to seek to an offset, in bytes, in a stream.

impl Sync for FuturesAsyncReader

Safety: FuturesAsyncReader only exposes &mut self to the outside world,