Skip to main content

photon_protocol/compressor/
noop.rs

1use bytes::BytesMut;
2
3use crate::ports::compress::{CompressionError, Compressor};
4
5#[derive(Clone, Debug)]
6pub struct NoopCompressor;
7
8impl NoopCompressor {
9    pub const NAME: &str = "none";
10}
11
12impl Compressor for NoopCompressor {
13    fn compress(&self, input: &[u8], output: &mut BytesMut) -> Result<(), CompressionError> {
14        output.extend_from_slice(input);
15        Ok(())
16    }
17
18    fn decompress(&self, input: &[u8], output: &mut BytesMut) -> Result<(), CompressionError> {
19        output.extend_from_slice(input);
20        Ok(())
21    }
22
23    fn name(&self) -> &'static str {
24        Self::NAME
25    }
26}