Struct Decoder

pub struct Decoder<'a> { /* private fields */ }

A decoder that decompresses data using the Zstandard algorithm.

Implementations

impl Decoder<'static>

pub fn new() -> (Self, Receiver<Vec<u8>>)

Creates a new Decoder and returns a receiver for the decompressed data.

The Decoder will decompress data in chunks and send the decompressed chunks over the returned mpsc::Receiver.

pub async fn decompress(&mut self, bytes: &[u8]) -> Result<(), Error>

Decompresses the given bytes and sends the decompressed data over the channel.

This method decompresses the input data in chunks, using a thread-local buffer to store the decompressed data. The decompressed chunks are then sent over the channel to the receiver.

pub async fn finish(self) -> Result<(), Error>

Flushes the decoder and sends any remaining decompressed data over the channel.

This method should always be called after all input data has been decompressed to ensure that all decompressed data is sent to the receiver.