Struct asyncio_utils::LimitSeekerReader

pub struct LimitSeekerReader<T>where
    T: AsyncRead + AsyncSeek + Unpin,{ /* private fields */ }

Implementations

impl<T> LimitSeekerReader<T>where T: AsyncRead + AsyncSeek + Unpin,

Implement a limit reader for AsyncRead and AsyncSeek together. Typically a file Note that if your seek does not affect total reads. You can seek with positive/negative from current/begin of file/end of file, but it does not change the total bytes would be read from the reader.

This is a little bit weird though. Typically what you want to do is just seek before reading.

This is useful when you want to service Http Get with Range requests.

You open tokio::fs::File you seek the position you set limit on number of bytes to read you start reading and serving.

pub fn new(src: T, limit: Option<usize>) -> LimitSeekerReader<T>

Create new LimitSeekerReader from another AsyncRead + AsyncSeek (typically file)

Argument src is the underlying reader + seeker limit is the byte limit. Node that the limit can be Some(limit) None -> No limit (std::usize::MAX)

Trait Implementations

impl<T> AsyncRead for LimitSeekerReader<T>where T: AsyncRead + AsyncSeek + Unpin,

Implementation of AsyncRead

fn poll_read( self: Pin<&mut Self>, ctx: &mut Context<'_>, data: &mut ReadBuf<'_> ) -> Poll<Result<(), Error>>

Attempts to read from the AsyncRead into buf.

impl<T> AsyncSeek for LimitSeekerReader<T>where T: AsyncRead + AsyncSeek + Unpin,

Implementation of AsyncSeek

fn start_seek(self: Pin<&mut Self>, from: SeekFrom) -> Result<(), Error>

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

fn poll_complete( self: Pin<&mut Self>, ctx: &mut Context<'_> ) -> Poll<Result<u64, Error>>

Waits for a seek operation to complete.