msgpack-rs 0.0.1

rust implementation of msgpack
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

mod code;
pub mod de;
pub mod pack;
mod pack_error;
mod packer;
pub mod primitive;
mod ser;
pub mod unpack;
mod unpack_error;
mod unpacker;
mod value;

pub use byteorder::ReadBytesExt;
pub use pack::*;
pub use pack_error::PackError;
pub use packer::Packer;
pub use unpack::*;
pub use unpack_error::UnpackError;
pub use unpacker::{InnerBuf, RefUnpacker, Unpacker};
pub use value::{RefValue, Value};

use std::io::{self, Cursor, Read};

pub trait BufferedRead<'a>: Read {
    // having same lifetime as BorrowRead
    fn fill_buf(&self) -> io::Result<&'a [u8]>;

    fn consume(&mut self, len: usize);
}

impl<'a> BufferedRead<'a> for &'a [u8] {
    fn fill_buf(&self) -> io::Result<&'a [u8]> {
        Ok(self)
    }

    fn consume(&mut self, len: usize) {
        *self = &(*self)[len..];
    }
}

impl<'a> BufferedRead<'a> for Cursor<&'a [u8]> {
    fn fill_buf(&self) -> io::Result<&'a [u8]> {
        let len = std::cmp::min(self.position(), self.get_ref().len() as u64);
        Ok(&self.get_ref()[len as usize..])
    }

    fn consume(&mut self, len: usize) {
        let pos = self.position();
        self.set_position(pos + len as u64);
    }
}