Fix program not exiting due to stdin receiver thread

SpacehuhnTech · Jun 8, 2020 · 6f5c392 · 6f5c392
1 parent 7466be2
commit 6f5c392
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/src/input.rs b/src/input.rs
@@ -5,7 +5,7 @@ use tokio::sync::mpsc::{UnboundedReceiver, UnboundedSender};
 use crate::error;
 use crate::output;
 
-pub async fn receiver(sender: UnboundedSender<String>) {
+pub fn receiver(sender: UnboundedSender<String>) {
     loop {
         let mut input = String::new();
         if io::stdin().read_line(&mut input).is_ok() {

diff --git a/src/main.rs b/src/main.rs
@@ -2,6 +2,7 @@ use serialport::prelude::*;
 use std::env;
 use std::time::Duration;
 use tokio::io::{AsyncBufReadExt, AsyncWriteExt, BufReader};
+use tokio::runtime::Runtime;
 
 #[macro_use]
 mod input;
@@ -40,7 +41,8 @@ fn parse_args() -> Arguments {
 
 async fn monitor(auto: bool, out: &output::Preferences) {
     let (sender, mut receiver) = tokio::sync::mpsc::unbounded_channel();
-    tokio::spawn(input::receiver(sender));
+
+    std::thread::spawn(|| { input::receiver(sender) });
 
     let settings = tokio_serial::SerialPortSettings {
         baud_rate: 115200,