rustbus 0.19.3

An implementation of the dbus protocol
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

use rustbus::connection::Timeout;
use rustbus::MessageBuilder;
use rustbus::RpcConn;
use rustbus::{Marshal, Signature};

#[derive(Marshal, Signature)]
struct Signal<'a> {
    abcd: u8,
    defgh: u64,
    b: &'a str,
}

fn main() {
    let mut con = RpcConn::session_conn(Timeout::Infinite).unwrap();

    let mut sig = MessageBuilder::new()
        .signal("io.killingspark", "Signal", "/io/killingspark/Signaler")
        .build();

    sig.body
        .push_param(Signal {
            abcd: 100,
            defgh: 200,
            b: "ABCDEFGH",
        })
        .unwrap();

    let mut buf = Vec::new();
    for _ in 0..20000000 {
        buf.clear();
        rustbus::wire::marshal::marshal(&sig, 1, &mut buf).unwrap();
    }

    // for _ in 0..50000000 {
    //     let _ = sig.body.parser().get::<(u8, u64, &str)>().unwrap().1;
    // }

    let ctx = con.send_message(&mut sig).unwrap();
    ctx.write_all().unwrap();

    println!("Sent message without a problem!");
}