mirror of
https://github.com/tokio-rs/tokio.git
synced 2026-08-07 00:00:09 +02:00
signal: new example: SIGHUP, shows how to receive other signals than ctrl+C
This commit is contained in:
committed by
Carl Lerche
parent
c601f68c9f
commit
36b58d8fa8
@@ -0,0 +1,33 @@
|
||||
extern crate futures;
|
||||
extern crate tokio_core;
|
||||
extern crate tokio_signal;
|
||||
|
||||
use futures::stream::Stream;
|
||||
use tokio_core::reactor::Core;
|
||||
use tokio_signal::unix::{Signal,SIGHUP};
|
||||
|
||||
fn main() {
|
||||
// set up a Tokio event loop
|
||||
let mut core = Core::new().unwrap();
|
||||
|
||||
// on Unix, we can listen to whatever signal we want, in this case: SIGHUP
|
||||
let sighup = Signal::new(SIGHUP, &core.handle());
|
||||
let stream = core.run(sighup).unwrap();
|
||||
|
||||
println!("Waiting for SIGHUPS (Ctrl+C to quit)");
|
||||
println!(" TIP: use `pkill -sighup sighup-example` from a second terminal to send a SIGHUP \
|
||||
to all processes named 'sighup-example' (i.e. this binary)");
|
||||
|
||||
// for_each is a powerful primitive provided by the Futures crate
|
||||
// it turns a Stream into a Future that completes after all stream-items
|
||||
// have been completed.
|
||||
let future = stream.for_each(|the_signal| {
|
||||
println!("*Got a signal {}* I should probably reload my config or something", the_signal);
|
||||
Ok(())
|
||||
});
|
||||
|
||||
// Up until now, we haven't really DONE anything, just prepared
|
||||
// now it's time to actually schedule, and thus execute, the stream
|
||||
// on our event loop, and loop forever
|
||||
core.run(future).unwrap();
|
||||
}
|
||||
Reference in New Issue
Block a user