[go: up one dir, main page]

protobuf 1.0.21

Rust implementation of Google 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
26
27
28
29
30
31
32
33

use std::thread;
use std::sync::Arc;

use protobuf::CodedInputStream;
use protobuf::Message;

use pb_basic::*;

// test messages are sync
#[test]
fn test_sync() {
    let m = Arc::new({
        let mut r = TestTypesSingular::new();
        r.set_int32_field(23);
        r
    });

    let threads: Vec<_> = (0..4).map(|_| {
        let m_copy = m.clone();
        thread::spawn(move || {
            let bytes = m_copy.write_to_bytes().unwrap();
            let mut is = CodedInputStream::from_bytes(&bytes);
            let mut read = TestTypesSingular::new();
            // API is not very convenient here
            read.merge_from(&mut is).unwrap();
            read.check_initialized().unwrap();
            read.get_int32_field()
        })
    }).collect();

    let results = threads.into_iter().map(|t| t.join().unwrap()).collect::<Vec<_>>();
    assert_eq!(&[23, 23, 23, 23], &results[..]);
}