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
61
62
63
64
65
66
67
68
69
70
71
72
73
74

use crate::synchronous::VariableWritable;

/// AP means all-platform. This is used for usize/isize converting to u128/i128.
/// CP means current-platform. It writes usize/isize directly.
#[allow(unused_macros)]
macro_rules! write_size_ap {
    (f $feature: meta, $primitive: ty, $func: ident, $internal: ty, $write_internal: ident) => {
        #[$feature]
        #[cfg_attr(docsrs, doc($feature))]
        #[inline]
        fn $func(&mut self, value: $primitive) -> ::core::result::Result<(), Self::Error> {
            self.$write_internal(value as $internal)
        }
    };
}

include!("write_bools.rs");

include!("write_raw.rs");
include!("write_raw_size.rs");

include!("write_varint.rs");
include!("write_varint_size.rs");
include!("write_varint_long.rs");
include!("write_varint_long_size.rs");

include!("write_signed_varint.rs");
include!("write_signed_varint_size.rs");
include!("write_signed_varint_long.rs");
include!("write_signed_varint_long_size.rs");

include!("write_float_varint.rs");
include!("write_float_varint_long.rs");

pub trait VariableWriter: VariableWritable {
    #[inline]
    fn write_bool(&mut self, b: bool) -> Result<(), Self::Error> {
        self.write_single(if b { 1 } else { 0 })
    }

    define_write_bools!();

    define_write_raw!();
    define_write_raw_size!();

    define_write_varint!();
    define_write_varint_size!();
    define_write_varint_long!();
    define_write_varint_long_size!();

    define_write_signed_varint!();
    define_write_signed_varint_size!();
    define_write_signed_varint_long!();
    define_write_signed_varint_long_size!();

    define_write_float_varint!();
    define_write_float_varint_long!();

    #[cfg(feature = "sync_u8_vec")]
    #[cfg_attr(docsrs, doc(cfg(feature = "sync_u8_vec")))]
    #[inline]
    fn write_u8_vec(&mut self, message: &[u8]) -> Result<(), Self::Error> {
        self.write_usize_varint_ap(message.len())?;
        self.write_more(message)?;
        Ok(())
    }

    #[cfg(feature = "sync_string")]
    #[cfg_attr(docsrs, doc(cfg(feature = "sync_string")))]
    #[inline]
    fn write_string(&mut self, message: &str) -> Result<(), Self::Error> {
        self.write_u8_vec(message.as_bytes())
    }
}