Trait kafka_protocol::compression::Decompressor

pub trait Decompressor<B: ByteBuf> {
    type Buf: ByteBuf;
    fn decompress<R, F>(buf: &mut B, f: F) -> Result<R, DecodeError>
    where
        F: FnOnce(&mut Self::Buf) -> Result<R, DecodeError>;
}

A trait for record decompression algorithms.

Associated Types

type Buf: ByteBuf

Target buffer type for decompression.

Required methods

fn decompress<R, F>(buf: &mut B, f: F) -> Result<R, DecodeError> where
    F: FnOnce(&mut Self::Buf) -> Result<R, DecodeError>, 

Decompress records from B mapped using F into R.

Implementors

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

type Buf = Bytes

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

type Buf = B

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

type Buf = Bytes