liboxen 0.9.4-beta3

Oxen is a fast, unstructured data version control, to help version datasets, written in Rust.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use indicatif::ProgressBar;
use std::sync::Arc;

pub struct ReadProgress<R> {
    pub inner: R,
    pub progress_bar: Arc<ProgressBar>,
}

impl<R: std::io::Read> std::io::Read for ReadProgress<R> {
    fn read(&mut self, buf: &mut [u8]) -> std::io::Result<usize> {
        let size = self.inner.read(buf).map(|n| {
            self.progress_bar.inc(n as u64);
            n
        });
        if self.progress_bar.elapsed() >= self.progress_bar.duration() {
            self.progress_bar.finish();
        }
        size
    }
}