Idiomatic imports with use.
authorSunil Nimmagadda <sunil@nimmagadda.net>
Wed, 07 Dec 2022 12:12:13 +0530
changeset 6 847fed6198dc
parent 5 b5394b113889
child 7 e3058ceb81cc
Idiomatic imports with use. This is not C and the line limit is 100 by default. Adjusting whitespace-line-column in emacs and let rustfmt handle wrapping long lines.
src/main.rs
--- a/src/main.rs	Mon Nov 28 19:29:30 2022 +0530
+++ b/src/main.rs	Wed Dec 07 12:12:13 2022 +0530
@@ -1,5 +1,5 @@
-use tokio::signal::unix::{signal, SignalKind};
-use tokio::{time::interval, time::Duration};
+use tokio::signal::unix;
+use tokio::time;
 
 const ADV_INTERVAL: u64 = 3;
 const SKEW_INTERVAL: u64 = 1;
@@ -19,21 +19,22 @@
 #[tokio::main(flavor = "current_thread")]
 async fn main() {
     let advert_handle = tokio::spawn(async move {
-        let mut advert_interval = interval(Duration::from_secs(ADV_INTERVAL));
+        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 = interval(Duration::from_secs(SKEW_INTERVAL));
+        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");
+        let mut stream =
+            unix::signal(unix::SignalKind::hangup()).expect("Should be a signal stream");
         loop {
             stream.recv().await;
             sighup_handler().await;