buf_read_splitter 0.3.1

Stream reader with capacity to split(stop) the stream on a defined pattern (usually &[u8] but can also more complex pattern)
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

use crate::buf_ext::BufExt;

pub struct BufExtIter<'a, 'b> {
    buf_ext: &'a mut BufExt<'b>,
    next_pos: usize,
}
impl<'a, 'b> BufExtIter<'a, 'b> {
    pub fn new(buf_ext: &'a mut BufExt<'b>) -> Self {
        Self {
            buf_ext,
            next_pos: 0,
        }
    }
}
impl<'a, 'b> Iterator for BufExtIter<'a, 'b> {
    type Item = std::io::Result<u8>;

    fn next(&mut self) -> Option<Self::Item> {
        if self.next_pos == self.buf_ext.len() {
            match self.buf_ext.extend() {
                Ok(sz) => {
                    if sz == 0 {
                        None //End of buffer
                    } else {
                        debug_assert!(self.next_pos < self.buf_ext.len(), "Abnormal position");

                        let old_val = self.next_pos;
                        self.next_pos += 1;
                        Some(Ok(self.buf_ext.at(old_val)))
                    }
                }
                Err(err) => Some(Err(err)),
            }
        } else {
            let old_val = self.next_pos;
            self.next_pos += 1;
            Some(Ok(self.buf_ext.at(old_val)))
        }
    }
}