mproto 0.2.3

The Rust runtime library for mproto schemas
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
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64

use crate::{
    BaseLen, Compatible, Decode, DecodeCursor, DecodeError, DecodeResult, Encode, EncodeCursor,
    Lazy, Owned,
};

impl<T: Owned> Owned for Option<T> {
    type Lazy<'a> = Option<T::Lazy<'a>>;

    fn lazy_to_owned(lazy: Self::Lazy<'_>) -> DecodeResult<Self> {
        match lazy {
            Some(lazy) => Ok(Some(T::lazy_to_owned(lazy)?)),
            None => Ok(None),
        }
    }
}

impl<'a, T: Lazy<'a>> Lazy<'a> for Option<T> {
    type Owned = Option<T::Owned>;
}

impl<T, U: Compatible<T>> Compatible<Option<T>> for Option<U> {}

impl<T: BaseLen> BaseLen for Option<T> {
    const BASE_LEN: usize = 1 + T::BASE_LEN;
}

impl<T: Encode> Encode for Option<T> {
    fn scratch_len(&self) -> usize {
        match self {
            Some(some) => some.scratch_len(),
            None => 0,
        }
    }

    fn encode(&self, cursor: &mut EncodeCursor) {
        match self {
            Some(some) => {
                cursor.base(1)[0] = 1;
                some.encode(cursor);
            }
            None => {
                cursor.base(1)[0] = 0;
                cursor.base(T::BASE_LEN);
            }
        }
    }
}

impl<'a, T: Decode<'a>> Decode<'a> for Option<T> {
    fn decode(cursor: &DecodeCursor<'a>) -> DecodeResult<Self> {
        let variant = cursor.base(1)[0];
        if variant > 1 {
            return Err(DecodeError);
        }

        let is_some = variant == 1;
        if is_some {
            Ok(Some(T::decode(cursor)?))
        } else {
            cursor.advance(T::BASE_LEN);
            Ok(None)
        }
    }
}