Function seq_io::parallel::read_process_records_init

pub fn read_process_records_init<R, Ri, W, F, O, Out, E>(
    reader_init: Ri, 
    n_workers: u32, 
    queue_len: usize, 
    work: W, 
    func: F
) -> Result<Option<Out>, E> where
    R: RecordSetReader,
    Ri: Send + FnOnce() -> Result<R, E>,
    R::RecordSet: Default + Send,
    &'a R::RecordSet: IntoIterator + Send,
    O: Default + Send,
    W: Send + Sync + Fn(<&R::RecordSet as IntoIterator>::Item, &mut O),
    F: FnMut(<&R::RecordSet as IntoIterator>::Item, &mut O) -> Option<Out>,
    E: From<<R as RecordSetReader>::Err> + Send, 

Using this function currently does not work due to a compiler bug.

read_process_fasta_records, read_process_fastq_records and read_process_fastx_records provide the same functionality for now (implemented using parallel_record_impl macro).