tbl-core 0.1.1

utilities for reading and modifying tabular files
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use futures::stream::{FuturesUnordered, StreamExt};
use std::path::Path;
use tokio::fs;

/// get total number of bytes across files
pub async fn get_total_bytes_of_files(file_paths: &[&Path]) -> Result<u64, std::io::Error> {
    let futures = file_paths.iter().map(|path| async move {
        let metadata = fs::metadata(path).await?;
        Ok::<u64, std::io::Error>(if metadata.is_file() {
            metadata.len()
        } else {
            0
        })
    });

    let mut total: u64 = 0;
    let mut futures: FuturesUnordered<_> = futures.collect();
    while let Some(result) = futures.next().await {
        total += result?;
    }

    Ok(total)
}