Struct Encoder

Source

pub struct Encoder { /* private fields */ }

Expand description

Wraps compression_stream_process for encoding.

Implementations§

Source §

impl Encoder

Source

pub fn new(algorithm: Algorithm) -> Result<Self>

Wraps new convenience around compression_stream_process.

Examples found in repository ?

examples/01_roundtrip.rs (line 10)

6fn main() -> Result<(), Box<dyn std::error::Error>> {
7    let input = pseudo_random_bytes(64 * 1024);
8    let split = input.len() / 2;
9
10    let mut encoder = Encoder::new(Algorithm::Lzfse)?;
11    let mut compressed = encoder.process(&input[..split])?;
12    compressed.extend(encoder.process(&input[split..])?);
13    compressed.extend(encoder.finish()?);
14
15    let mut decoder = Decoder::new(Algorithm::Lzfse)?;
16    let encoded_split = compressed.len() / 2;
17    let mut round_trip = decoder.process(&compressed[..encoded_split])?;
18    round_trip.extend(decoder.process(&compressed[encoded_split..])?);
19    round_trip.extend(decoder.finish()?);
20
21    assert_eq!(round_trip, input);
22    let input_len = input.len();
23    let compressed_len = compressed.len();
24    println!("input={input_len} compressed={compressed_len}");
25    println!("✅ compression stream round-trip OK");
26    Ok(())
27}

Source

pub fn process(&mut self, input: &[u8]) -> Result<Vec<u8>>

Wraps process convenience around compression_stream_process.

Examples found in repository ?

examples/01_roundtrip.rs (line 11)

6fn main() -> Result<(), Box<dyn std::error::Error>> {
7    let input = pseudo_random_bytes(64 * 1024);
8    let split = input.len() / 2;
9
10    let mut encoder = Encoder::new(Algorithm::Lzfse)?;
11    let mut compressed = encoder.process(&input[..split])?;
12    compressed.extend(encoder.process(&input[split..])?);
13    compressed.extend(encoder.finish()?);
14
15    let mut decoder = Decoder::new(Algorithm::Lzfse)?;
16    let encoded_split = compressed.len() / 2;
17    let mut round_trip = decoder.process(&compressed[..encoded_split])?;
18    round_trip.extend(decoder.process(&compressed[encoded_split..])?);
19    round_trip.extend(decoder.finish()?);
20
21    assert_eq!(round_trip, input);
22    let input_len = input.len();
23    let compressed_len = compressed.len();
24    println!("input={input_len} compressed={compressed_len}");
25    println!("✅ compression stream round-trip OK");
26    Ok(())
27}

Source

pub fn finish(&mut self) -> Result<Vec<u8>>

Wraps finish convenience around compression_stream_process.

Examples found in repository ?

examples/01_roundtrip.rs (line 13)

6fn main() -> Result<(), Box<dyn std::error::Error>> {
7    let input = pseudo_random_bytes(64 * 1024);
8    let split = input.len() / 2;
9
10    let mut encoder = Encoder::new(Algorithm::Lzfse)?;
11    let mut compressed = encoder.process(&input[..split])?;
12    compressed.extend(encoder.process(&input[split..])?);
13    compressed.extend(encoder.finish()?);
14
15    let mut decoder = Decoder::new(Algorithm::Lzfse)?;
16    let encoded_split = compressed.len() / 2;
17    let mut round_trip = decoder.process(&compressed[..encoded_split])?;
18    round_trip.extend(decoder.process(&compressed[encoded_split..])?);
19    round_trip.extend(decoder.finish()?);
20
21    assert_eq!(round_trip, input);
22    let input_len = input.len();
23    let compressed_len = compressed.len();
24    println!("input={input_len} compressed={compressed_len}");
25    println!("✅ compression stream round-trip OK");
26    Ok(())
27}