ipmb 0.8.5

Inter-process message bus
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

use ipmb::label;
use std::time::Duration;

fn main() {
    let mut builder = env_logger::Builder::new();
    builder.filter_level(log::LevelFilter::Info);
    builder.parse_default_env();
    builder.init();

    let option = ipmb::Options::new("com.solar", label!("moon"), "");

    {
        let (_sender, _receiver) =
            ipmb::join::<(), ()>(option.clone(), None).expect("Join solar.com failed");
    }

    let (_sender, mut receiver) =
        ipmb::join::<(), ()>(option, None).expect("Join solar.com failed");

    loop {
        match receiver.recv(Some(Duration::from_millis(500))) {
            Err(ipmb::RecvError::Timeout) => {
                log::info!("Timeout");
                continue;
            }
            _ => break,
        }
    }
}