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

extern crate futures;
extern crate pbcodec;
#[macro_use]
extern crate trackable;

use futures::Future;
use pbcodec::{Decode, Encode};
use pbcodec::fields::PackedRepeatedField;
use pbcodec::tags::Tag1;
use pbcodec::types::Int32;

#[test]
fn packed_repeated_works() {
    type M = (PackedRepeatedField<Tag1, Int32>,);

    let v: M = (vec![Int32(0), Int32(1), Int32(2)].into(),);
    let bytes = track_try_unwrap!(v.encode(Vec::new()).wait());
    assert_eq!(bytes, [10, 3, 0, 1, 2]);

    let (_, m) = track_try_unwrap!(M::decode(&bytes[..]).wait());
    assert_eq!(
        m.0.values.into_iter().map(|v| v.0).collect::<Vec<_>>(),
        [0, 1, 2]
    );
}