extern crate futures; extern crate tokio_core; extern crate tokio_signal; use futures::stream::Stream; use tokio_core::reactor::Core; fn main() { let mut core = Core::new().unwrap(); let ctrlc = tokio_signal::ctrl_c(&core.handle()); let stream = core.run(ctrlc).unwrap(); core.run(stream.for_each(|()| { println!("Ctrl-C received!"); Ok(()) })).unwrap(); }