Struct StreamCompressor 

pub struct StreamCompressor { /* private fields */ }

A handle to the streaming compressor.

Implementations

impl StreamCompressor

pub fn sender(&self) -> &Sender<ArchiveEntry>

Examples found in repository

examples/bench_stream.rs (line 58)

fn run_once(kind: &str, entries: Vec<ArchiveEntry>, archive: &std::path::PathBuf) -> (f64, u64, u64) {
    let input_bytes: u64 = entries.iter().map(|e| e.data.len() as u64).sum();
    let t0 = Instant::now();
    let compressor = compress_stream(archive, false).expect("compress_stream");
    for e in entries {
        compressor.sender().send(e).expect("send");
    }
    let report = compressor.finish().expect("finish");
    let secs = t0.elapsed().as_secs_f64();
    let _ = kind;
    (secs, input_bytes, report.chunks)
}

pub fn finish(self) -> Result<CompressionReport>

Examples found in repository

examples/bench_stream.rs (line 60)

fn run_once(kind: &str, entries: Vec<ArchiveEntry>, archive: &std::path::PathBuf) -> (f64, u64, u64) {
    let input_bytes: u64 = entries.iter().map(|e| e.data.len() as u64).sum();
    let t0 = Instant::now();
    let compressor = compress_stream(archive, false).expect("compress_stream");
    for e in entries {
        compressor.sender().send(e).expect("send");
    }
    let report = compressor.finish().expect("finish");
    let secs = t0.elapsed().as_secs_f64();
    let _ = kind;
    (secs, input_bytes, report.chunks)
}