[−][src]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).