--- a/src/bin/main.rs Mon Nov 28 15:01:40 2022 +0530
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,43 +0,0 @@
-use tokio::signal::unix::{signal, SignalKind};
-use tokio::time;
-
-const ADV_INTERVAL: u64 = 3;
-const SKEW_INTERVAL: u64 = 1;
-
-async fn advert_handler() {
- println!("3 second timer fired");
-}
-
-async fn skew_handler() {
- println!("1 second timer fired");
-}
-
-async fn sighup_handler() {
- println!("got SIGHUP");
-}
-
-#[tokio::main(flavor = "current_thread")]
-async fn main() {
- let advert_handle = tokio::spawn(async move {
- let mut advert_interval = time::interval(time::Duration::from_secs(ADV_INTERVAL));
- loop {
- advert_interval.tick().await;
- advert_handler().await;
- }
- });
- let skew_handle = tokio::spawn(async move {
- let mut skew_interval = time::interval(time::Duration::from_secs(SKEW_INTERVAL));
- loop {
- skew_interval.tick().await;
- skew_handler().await;
- }
- });
- let sighup_handle = tokio::spawn(async move {
- let mut stream = signal(SignalKind::hangup()).expect("Should be a signal stream");
- loop {
- stream.recv().await;
- sighup_handler().await;
- }
- });
- let (_, _, _) = tokio::join!(advert_handle, skew_handle, sighup_handle);
-}
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/src/main.rs Mon Nov 28 15:42:07 2022 +0530
@@ -0,0 +1,43 @@
+use tokio::signal::unix::{signal, SignalKind};
+use tokio::time;
+
+const ADV_INTERVAL: u64 = 3;
+const SKEW_INTERVAL: u64 = 1;
+
+async fn advert_handler() {
+ println!("3 second timer fired");
+}
+
+async fn skew_handler() {
+ println!("1 second timer fired");
+}
+
+async fn sighup_handler() {
+ println!("got SIGHUP");
+}
+
+#[tokio::main(flavor = "current_thread")]
+async fn main() {
+ let advert_handle = tokio::spawn(async move {
+ let mut advert_interval = time::interval(time::Duration::from_secs(ADV_INTERVAL));
+ loop {
+ advert_interval.tick().await;
+ advert_handler().await;
+ }
+ });
+ let skew_handle = tokio::spawn(async move {
+ let mut skew_interval = time::interval(time::Duration::from_secs(SKEW_INTERVAL));
+ loop {
+ skew_interval.tick().await;
+ skew_handler().await;
+ }
+ });
+ let sighup_handle = tokio::spawn(async move {
+ let mut stream = signal(SignalKind::hangup()).expect("Should be a signal stream");
+ loop {
+ stream.recv().await;
+ sighup_handler().await;
+ }
+ });
+ let (_, _, _) = tokio::join!(advert_handle, skew_handle, sighup_handle);
+}