pbcodec 0.0.8

An asynchronous encoder/decoder for Protocol Buffers
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

use std::io::Read;

use Decode;
use future::read::{ReadAllBytes, ReadBytes};

impl<R: Read> Decode<R> for [u8; 4] {
    type Future = ReadBytes<R, Self>;
    fn decode(reader: R) -> Self::Future {
        ReadBytes::new(reader, [0; 4])
    }
}

impl<R: Read> Decode<R> for [u8; 8] {
    type Future = ReadBytes<R, Self>;
    fn decode(reader: R) -> Self::Future {
        ReadBytes::new(reader, [0; 8])
    }
}

impl<R: Read> Decode<R> for Vec<u8> {
    type Future = ReadAllBytes<R>;
    fn decode(reader: R) -> Self::Future {
        ReadAllBytes::new(reader)
    }
}