extern crate cocaine;
extern crate futures;
extern crate tokio_core;
use futures::{Future, Stream, future};
use tokio_core::reactor::Core;
use cocaine::Service;
use cocaine::service::Locator;
fn main() {
let mut core = Core::new().unwrap();
let locator = Locator::new(Service::new("locator", &core.handle()));
let future = locator.resolve("node").and_then(|info| {
println!("{:?}", info);
future::ok(())
});
core.run(future).unwrap();
let stream = locator.routing("whatever").for_each(|chunk| {
println!("{:?}", chunk);
future::ok(())
});
core.run(stream).unwrap();
}