Trait kafka_protocol::compression::Decompressor

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

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

A trait for record decompression algorithms.

Required Associated Types§

source

type Buf: ByteBuf

Target buffer type for decompression.

Required Methods§

source

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§