itsscb/tokio
1
0
Fork 0
mirror of https://github.com/tokio-rs/tokio.git synced 2025-10-01 12:20:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

signal: Ctrl+C example: more explanations

Browse Source
This commit is contained in:
Jules Kerssemakers 2017-06-08 15:59:04 +02:00 committed by Carl Lerche
parent 6a7092b9f7
commit 72e2209bd8
1 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
examples/ctrl-c.rs
View File

@ -18,13 +18,19 @@ fn main() {
// stream we want, reducing boilerplate Future-handling. // stream we want, reducing boilerplate Future-handling.
let stream = tokio_signal::ctrl_c(&core.handle()).flatten_stream(); let stream = tokio_signal::ctrl_c(&core.handle()).flatten_stream();
println!("This program is now waiting for you to press Ctrl+C"); println!("This program is now waiting for you to press Ctrl+C
* If running via `cargo run --example ctrl-c`, Ctrl+C also kills it, \
due to https://github.com/rust-lang-nursery/rustup.rs/issues/806
* If running the binary directly, the Ctrl+C is properly trapped. \
Terminate by opening a second terminal and issue `pkill -sigkil ctrl-c`");
// for_each is a powerful primitive provided by the Futures crate // Stream::for_each is a powerful primitive provided by the Futures crate.
// it turns a Stream into a Future that completes after all stream-items // It turns a Stream into a Future that completes after all stream-items
// have been completed. // have been completed, or the first time the closure returns an error
let future = stream.for_each(|()| { let future = stream.for_each(|()| {
println!("Ctrl+C received!"); println!("Ctrl+C received!");
// return Ok-result to continue handling the stream
Ok(()) Ok(())
}); });