1extern crate tokio_process_bits;
2extern crate futures;
3extern crate tokio_core;
4
5use tokio_process_bits::execute;
6use futures::Stream;
7
8pub fn main() {
9 let mut core = ::tokio_core::reactor::Core::new().unwrap();
10 let handle = core.handle();
11
12 let c1 = execute(&handle, "ping", vec!["127.0.0.1"]).unwrap();
13 let c2 = execute(&handle, "ping", vec!["0.0.0.0"]).unwrap();
14
15 let lines = c1.stdout.select(c2.stdout).for_each(|line| {
16 println!("LINE: {}", line);
17 ::futures::future::ok(())
18 });
19
20 core.run(lines).unwrap();
21}