hydraulic 0.1.0

An interface for generic compression library usage with a collection (unimplemented so far) of pre-existing compression libraries
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
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64

use crate::features::gz::Gzip;
use crate::prelude::ReadDecoder;
use crate::tests::util::generate_random_bytes;
use crate::write::compress::WriteEncoder;
use crate::CompressionLevel;
use std::fs::File;

#[test]
fn write_read_high() {
    let data = generate_random_bytes();
    
    let alg = Gzip::new();

    let mut compressor = WriteEncoder::new(&alg, File::create("foo.txt").unwrap(), CompressionLevel::High);
    compressor.queue(&data);
    compressor.write().unwrap();
    let finalised = compressor.finish().unwrap();
    
    let alg = Gzip::new();

    let mut decompressor = ReadDecoder::new(&alg, finalised);
    decompressor.read_all().unwrap();
    let decompressed = decompressor.finish().unwrap();

    assert_eq!(data, &*decompressed)
}
#[test]
fn write_read_med() {
    let data = generate_random_bytes();
    
    let alg = Gzip::new();

    let mut compressor = WriteEncoder::new(&alg, File::create("foo.txt").unwrap(), CompressionLevel::Med);
    compressor.queue(&data);
    compressor.write().unwrap();
    let finalised = compressor.finish().unwrap();

    let alg = Gzip::new();

    let mut decompressor = ReadDecoder::new(&alg, finalised);
    decompressor.read_all().unwrap();
    let decompressed = decompressor.finish().unwrap();

    assert_eq!(data, &*decompressed)
}
#[test]
fn write_read_low() {
    let data = generate_random_bytes();

    let alg = Gzip::new();
    
    let mut compressor = WriteEncoder::new(&alg, File::create("foo.txt").unwrap(), CompressionLevel::Low);
    compressor.queue(&data);
    compressor.write().unwrap();
    let finalised = compressor.finish().unwrap();

    let alg = Gzip::new();

    let mut decompressor = ReadDecoder::new(&alg, finalised);
    decompressor.read_all().unwrap();
    let decompressed = decompressor.finish().unwrap();

    assert_eq!(data, &*decompressed)
}