reconnect after errors

src/bin.rs

@@ -1,13 +1,27 @@
 use mhz19::MHZ19;
 use std::time::Duration;
 use std::thread::sleep;
+use std::ffi::OsStr;
+
+const DELAY: Duration = Duration::from_secs(1);
 
 fn main() {
-    let mut mhz19 = MHZ19::open("/dev/ttyUSB0").unwrap();
-    let delay = Duration::from_secs(1);
     loop {
-        let value = mhz19.read().unwrap();
+        listen("/dev/ttyUSB0");
-        println!("{}", value);
+        sleep(DELAY);
-        sleep(delay);
+    }
+}
+
+fn listen<T: AsRef<OsStr> + ?Sized>(port: &T) {
+    let mut mhz19 = MHZ19::open(port).unwrap();
+    loop {
+        match { mhz19.read()} {
+            Ok(value) => println!("{}", value),
+            Err(err) => {
+                eprintln!("Error while reading value: {}, reconnecting", err);
+                return;
+            }
+        };
+        sleep(DELAY);
     }
 }