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
pub mod varint;
pub mod packed_bool;
pub mod delta;
use crate::prelude::*;
pub fn read_all<T>(bytes: &[u8], f: impl Fn(&[u8], &mut usize)->ReadResult<T>) -> ReadResult<Vec<T>> {
let mut offset = 0;
let mut result = Vec::new();
while offset < bytes.len() {
let read = f(bytes, &mut offset)?;
result.push(read);
}
debug_assert_eq!(offset, bytes.len());
Ok(result)
}
#[cfg(test)]
mod tests {
use super::*;
use std::fmt::Debug;
pub fn round_trip<T: Copy + PartialEq + Debug>(data: &[T], encoder: impl Fn(T, &mut Vec<u8>), decoder: impl Fn(&[u8], &mut usize)->ReadResult<T>) -> ReadResult<()> {
let mut bytes = Vec::new();
for value in data.iter() {
encoder(*value, &mut bytes);
}
let result = read_all(&bytes, decoder)?;
assert_eq!(&result, &data);
Ok(())
}
}