noodles_fastq/io/reader/
records.rs

1use std::io::{self, BufRead};
2
3use crate::Record;
4
5use super::Reader;
6
7/// An iterator over records of a FASTQ reader.
8///
9/// This is created by calling [`Reader::records`].
10pub struct Records<'a, R> {
11    inner: &'a mut Reader<R>,
12    buf: Record,
13}
14
15impl<'a, R> Records<'a, R>
16where
17    R: BufRead,
18{
19    pub(crate) fn new(inner: &'a mut Reader<R>) -> Self {
20        Self {
21            inner,
22            buf: Record::default(),
23        }
24    }
25}
26
27impl<R> Iterator for Records<'_, R>
28where
29    R: BufRead,
30{
31    type Item = io::Result<Record>;
32
33    fn next(&mut self) -> Option<Self::Item> {
34        self.buf.clear();
35
36        match self.inner.read_record(&mut self.buf) {
37            Ok(0) => None,
38            Ok(_) => Some(Ok(self.buf.clone())),
39            Err(e) => Some(Err(e)),
40        }
41    }
42}

noodles_fastq/io/reader/records.rs

noodles_fastq/io/reader/
records.rs