Timeout

grumlimited · Oct 20, 2023 · 2a7cdbe · 2a7cdbe
1 parent a01b7a2
commit 2a7cdbe
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/src/cli_helpers.rs b/src/cli_helpers.rs
@@ -84,7 +84,7 @@ pub struct Opt {
     #[structopt(short, long)]
     pub verbose: bool,
 
-    /// Exits of no messages received after <timeout> seconds.
+    /// Exits if no messages received after <timeout> seconds.
     #[structopt(long)]
     pub timeout: Option<u16>,
 }

diff --git a/src/kinesis/ticker.rs b/src/kinesis/ticker.rs
@@ -92,7 +92,10 @@ impl Ticker {
                         let duration = Utc::now() - last_ts;
 
                         if duration.num_milliseconds() > (timeout * 1000) as i64 {
-                            tx_records.send(Err(Timeout(duration))).await.unwrap();
+                            tx_records
+                                .send(Err(Timeout(duration)))
+                                .await
+                                .expect("Could not sent Timeout to tx_records");
                         }
 
                         sleep(delay).await