Trait Decompressor 

pub trait Decompressor:
    Send
    + Sync
    + Unpin
    + 'static {
    // Required method
    fn decompress(&self, data: &[u8]) -> Result<Bytes, Error>;
}

This trait is used to implement message-level decompression algorithms for payloads. On incoming messages, the payload is decompressed using the decompress method.

Required Methods

fn decompress(&self, data: &[u8]) -> Result<Bytes, Error>

Decompresses a compressed byte slice into a Bytes object.

Implementors

impl Decompressor for GzipDecompressor

impl Decompressor for Lz4Decompressor

impl Decompressor for SnappyDecompressor

impl Decompressor for ZstdDecompressor