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
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
use crate::{ContextualReadable, ReadResult, Readable};
use bytes::Buf;
macro_rules! implement {
($($reader:ident, $ty:ty => $expr:expr),*$(,)?) => {
$(
impl $crate::Readable for $ty {
fn read_from($reader: &mut impl bytes::Buf) -> Result<Self, $crate::ReadError> {
Ok($expr)
}
}
)*
};
}
implement! {
reader, i8 => reader.get_i8(),
reader, i16 => reader.get_i16(),
reader, i32 => reader.get_i32(),
reader, i64 => reader.get_i64(),
reader, i128 => reader.get_i128(),
reader, u8 => reader.get_u8(),
reader, u16 => reader.get_u16(),
reader, u32 => reader.get_u32(),
reader, u64 => reader.get_u64(),
reader, u128 => reader.get_u128(),
reader, f32 => reader.get_f32(),
reader, f64 => reader.get_f64(),
reader, bool => reader.get_u8() != 0,
}
impl<T: Readable, const N: usize> Readable for [T; N] {
fn read_from(reader: &mut impl Buf) -> ReadResult<Self>
where
Self: Sized,
{
let mut vec = Vec::new();
for _ in 0..N {
vec.push(T::read_from(reader)?);
}
Ok(match vec.try_into() {
Ok(array) => array,
Err(_) => unreachable!("we know the length of this vec is `N`"),
})
}
}
impl<T: Readable> ContextualReadable for Vec<T> {
type Context = usize;
fn read_with(reader: &mut impl Buf, context: &Self::Context) -> ReadResult<Self>
where
Self: Sized,
{
let mut vec = Vec::new();
for _ in 0..*context {
vec.push(T::read_from(reader)?);
}
Ok(vec)
}
}