Enum AsyncCompressReader 

pub enum AsyncCompressReader<R> {
    None(BufReader<R>),
    Zstd(Box<AsyncZstdSeekableReader<'static, BufReader<R>>>),
}

Variants

None(BufReader<R>)

Zstd(Box<AsyncZstdSeekableReader<'static, BufReader<R>>>)

Implementations

impl<R: AsyncRead + AsyncSeek + Unpin> AsyncCompressReader<R>

pub async fn new(inner: R) -> Result<Self>

Create a new AsyncCompressReader from a reader

It will detect the compression type using magic bytes and return the appropriate reader.

Note: The reader will be return to the start after detecting the compression type.

pub fn compress_type(&self) -> CompressType

impl AsyncCompressReader<File>

pub async fn file_size(&mut self) -> Result<u64>

Trait Implementations

impl<R: AsyncRead + AsyncSeek + Unpin> AsyncBufRead for AsyncCompressReader<R>

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

Attempts 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<R: AsyncRead + AsyncSeek + Unpin> AsyncRead for AsyncCompressReader<R>

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

Attempts to read from the AsyncRead into buf.

impl<R: AsyncRead + AsyncSeek + Unpin> AsyncSeek for AsyncCompressReader<R>

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

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

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

Waits for a seek operation to complete.