Trait Decompressor

pub trait Decompressor<B: ByteBuf> {
    type Buf: ByteBuf;

    // Required method
    fn decompress<R, F>(buf: &mut B, f: F) -> Result<R>
       where F: FnOnce(&mut Self::Buf) -> Result<R>;
}

A trait for record decompression algorithms.

Required Associated Types

type Buf: ByteBuf

Target buffer type for decompression.

Required Methods

fn decompress<R, F>(buf: &mut B, f: F) -> Result<R>

where F: FnOnce(&mut Self::Buf) -> Result<R>,

Decompress records from B mapped using F into R.

Object Safety

This trait is not object safe.

Implementors

impl<B: ByteBuf> Decompressor<B> for Gzip

Available on crate feature gzip only.

type Buf = Bytes

impl<B: ByteBuf> Decompressor<B> for Lz4

Available on crate feature lz4 only.

type Buf = Bytes

impl<B: ByteBuf> Decompressor<B> for None

type Buf = B

impl<B: ByteBuf> Decompressor<B> for Snappy

Available on crate feature snappy only.

type Buf = Bytes

impl<B: ByteBuf> Decompressor<B> for Zstd

Available on crate feature zstd only.

type Buf = Bytes