dsmr-parse 0.4.2

Library for parsing DSMR telegrams
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

use std::io;

pub struct LineReader<B> {
	inner: B,
}

impl<B: Iterator<Item = io::Result<u8>>> LineReader<B> {
	pub fn new(inner: B) -> Self {
		Self { inner }
	}
}

impl<B: Iterator<Item = io::Result<u8>>> Iterator for LineReader<B> {
	type Item = io::Result<Vec<u8>>;

	fn next(&mut self) -> Option<Self::Item> {
		let mut line = Vec::with_capacity(64);
		loop {
			match self.inner.next()? {
				Ok(b) => {
					if b == b'\n' {
						if line.ends_with(b"\r") {
							line.pop();
						}
						break Some(Ok(line));
					}
					line.push(b);
				}
				Err(e) => break Some(Err(e)),
			}
		}
	}
}