Struct kafka_protocol::compression::None

pub struct None;

Noop compression implementation.

Trait Implementations

impl<B: ByteBufMut> Compressor<B> for None

type BufMut = B

Target buffer type for compression.

fn compress<R, F>(buf: &mut B, f: F) -> Result<R, EncodeError>where
    F: FnOnce(&mut Self::BufMut) -> Result<R, EncodeError>,

Compresses into provided ByteBufMut, with records encoded by F into R.

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

type Buf = B

Target buffer type for decompression.

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.