variable-len-reader 3.2.1

A library for reading/writing variable length data. Support AsyncRead/AsyncWrite in tokio.
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

#![allow(deprecated)]

include!("func/value_generator.rs");

macro_rules! test_func {
    (@ $cursor: ident, $source: expr, $tester: ident, $reader: ident, $writer: ident, |$a: ident, $b: ident| $eq: expr) => { {
        use variable_len_reader::asynchronous::reader::AsyncVariableReader;
        use variable_len_reader::asynchronous::writer::AsyncVariableWriter;
        $cursor.set_position(0);
        let source = $source;
        $cursor.$writer(source.clone()).await.expect(&format!("writing failed. tester={}, source={:?}", stringify!($tester), source));
        let len = $cursor.position();
        $cursor.set_position(0);
        let target = $cursor.$reader().await.expect(&format!("reading failed. tester={}, source={:?}, len={}, buffer={:?}", stringify!($tester), source, len, $cursor));
        assert!({ let $a = source.clone(); let $b = target.clone(); $eq },
            "comparing failed. {:?} != {:?}. tester={}. buffer: {:?}", source, target, stringify!($tester), $cursor);
        let pos = $cursor.position();
        assert_eq!(pos, len, "checking failed. {} != {}. tester={}. source={:?}", pos,  len, stringify!($tester), source);
    } };
    ($tester: ident, $reader: ident, $writer: ident @a $primitive: ty) => {
        #[tokio::test]
        async fn $tester() {
            let mut cursor = std::io::Cursor::new(Vec::new());
            for p in <$primitive>::MIN..=<$primitive>::MAX {
                test_func!(@ cursor, p, $tester, $reader, $writer, |a, b| a == b);
            }
        }
    };
    ($tester: ident, $reader: ident, $writer: ident @m $source: expr, |$a: ident, $b: ident| $eq: expr) => {
        #[tokio::test]
        async fn $tester() {
            let mut cursor = std::io::Cursor::new(Vec::new());
            for source in $source {
                test_func!(@ cursor, source, $tester, $reader, $writer, |$a, $b| $eq);
            }
        }
    };
    ($tester: ident, $reader: ident, $writer: ident @m $source: expr) => {
        test_func!($tester, $reader, $writer @m $source, |a, b| a == b);
    };
    ($tester: ident, $reader: ident, $writer: ident @g $primitive: ident) => {
        test_func!($tester, $reader, $writer @m test_value_generator!($primitive));
    };
}

include!("func/bools.rs");

include!("func/raw.rs");

include!("func/varint.rs");
include!("func/varint_signed.rs");
include!("func/varint_float.rs");

include!("func/string.rs");

test_func!(u8_vec, read_u8_vec, write_u8_vec @m test_u8_vec_values!(|v| v.to_vec()));
test_func!(u8_vec_boxed, read_u8_vec_boxed, write_u8_vec_boxed @m test_u8_vec_values!());

test_func!(string, read_string, write_string @m test_string_values!(|s| s.to_string()));
test_func!(string_boxed, read_string_boxed, write_string_boxed @m test_string_values!());