seq_io_parallel 0.2.1

A map-reduce style parallel extension to seq_io
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

use anyhow::Result;
use seq_io::policy;
use std::io;

use crate::ParallelProcessor;

pub trait ParallelReader<R, P>
where
    R: io::Read + Send,
    P: policy::BufPolicy + Send,
{
    fn process_parallel<T>(self, processor: T, num_threads: usize) -> Result<()>
    where
        T: ParallelProcessor;
}