cocaine 0.9.2

Cocaine Framework Rust
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

extern crate cocaine;
extern crate futures;
#[macro_use]
extern crate serde_derive;

use futures::{Future, Stream};

use cocaine::{Core, Service};
use cocaine::service::Unicorn;

#[derive(Debug, Deserialize)]
struct Resource {
    cpu: i64,
    mem: i64,
    net: i64,
}

fn main() {
    let mut core = Core::new().unwrap();
    let unicorn = Unicorn::new(Service::new("unicorn", &core.handle()));

    let future = unicorn.children_subscribe("/darkvoice/resources".into(), None).and_then(|(tx, stream)| {
        stream.take(1).for_each(|(version, nodes)| {
            println!("Version: {}, nodes: {:?}", version, nodes);

            let mut futures = Vec::with_capacity(5001);
            for node in nodes {
                futures.push(unicorn.get::<Resource,_>(&format!("/darkvoice/resources/{}", node), None));
            }

            futures::future::join_all(futures).and_then(|result| {
                println!("Result: {:?}", result);
                Ok(())
            })
        }).and_then(|()| {
            drop(tx);
            Ok(())
        })
    });
    core.run(future).unwrap();
}