fastq 0.2.0

A parser for fastq
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51

# A fast parser for fastq.

This library can process fastq files at about the speed of the
coreutils `wc -l` (about 2GB/s on my laptop). It also makes it
easy to distribute the processing of fastq records to many
cores.

See the documentation for details.

# Examples

Count the number of fastq records that contain an `N`

```rust
use fastq::{Parser, Record};
let reader = ::std::io::stdin();
let mut parser = Parser::new(reader);
let mut total: usize = 0;

parser.each(|record| {
   if record.seq().contains(&b'N') {
       total += 1
   }
}).unwrap();
println!("{}", total);
```

And an (unnecessarily) parallel version of this

```rust
const n_threads: usize = 2;

use fastq::{Parser, Record};
let reader = ::std::io::stdin();
let parser = Parser::new(reader);

let results: Vec<u64> = parser.parallel_each(n_threads, |record_sets| {
    let mut thread_total = 0;
    for record_set in record_sets {
        for record in record_set.iter() {
            if record.seq().contains(&b'N') {
                thread_total += 1;
            }
        }
    }
    thread_total
}).expect("Invalid fastq file");

let total: u64 = results.iter().sum();
println!("{}", total);
```