pulsar-binary-protocol-spec 0.0.1

Pulsar binary protocol specification
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

use std::io::{self, Write};

use flate2::{
    write::{ZlibDecoder, ZlibEncoder},
    Compression,
};

pub fn compress(slice: &[u8], w: &mut Vec<u8>) -> io::Result<()> {
    let mut encoder = ZlibEncoder::new(w, Compression::default());
    encoder.write_all(slice)?;
    encoder.finish().map(|_| ())
}

pub fn decompress(slice: &[u8], w: &mut Vec<u8>) -> io::Result<()> {
    let mut decoder = ZlibDecoder::new(w);
    decoder.write_all(slice)?;
    decoder.finish().map(|_| ())
}

#[cfg(test)]
mod tests {
    use super::*;

    use std::error;

    #[test]
    fn simple() -> Result<(), Box<dyn error::Error>> {
        let mut buf = Vec::new();
        compress(b"foo", &mut buf)?;
        let compressed_bytes = buf.to_vec();

        println!("compressed_bytes {:?}", compressed_bytes);

        let mut buf = Vec::new();
        decompress(&compressed_bytes[..], &mut buf)?;
        assert_eq!(buf, b"foo");

        Ok(())
    }
}