dont use process abort on input thread error (#823)

rather perform a graceful shutdown

Author: Stephan Dilly

src/app.rs

@@ -395,8 +395,8 @@ impl App {
 	}
 
 	///
-	pub const fn is_quit(&self) -> bool {
-		self.do_quit
+	pub fn is_quit(&self) -> bool {
+		self.do_quit || self.input.is_aborted()
 	}
 
 	///

src/input.rs

@@ -3,7 +3,6 @@ use anyhow::Result;
 use crossbeam_channel::{unbounded, Receiver, Sender};
 use crossterm::event::{self, Event};
 use std::{
-	process,
 	sync::{
 		atomic::{AtomicBool, Ordering},
 		Arc,
@@ -33,6 +32,7 @@ pub struct Input {
 	desired_state: Arc<NotifyableMutex<bool>>,
 	current_state: Arc<AtomicBool>,
 	receiver: Receiver<InputEvent>,
+	aborted: Arc<AtomicBool>,
 }
 
 impl Input {
@@ -42,23 +42,26 @@ impl Input {
 
 		let desired_state = Arc::new(NotifyableMutex::new(true));
 		let current_state = Arc::new(AtomicBool::new(true));
+		let aborted = Arc::new(AtomicBool::new(false));
 
 		let arc_desired = Arc::clone(&desired_state);
 		let arc_current = Arc::clone(&current_state);
+		let arc_aborted = Arc::clone(&aborted);
 
 		thread::spawn(move || {
 			if let Err(e) =
 				Self::input_loop(&arc_desired, &arc_current, &tx)
 			{
 				log::error!("input thread error: {}", e);
-				process::abort();
+				arc_aborted.store(true, Ordering::SeqCst);
 			}
 		});
 
 		Self {
 			receiver: rx,
 			desired_state,
 			current_state,
+			aborted,
 		}
 	}
 
@@ -82,6 +85,10 @@ impl Input {
 			!= self.current_state.load(Ordering::Relaxed)
 	}
 
+	pub fn is_aborted(&self) -> bool {
+		self.aborted.load(Ordering::SeqCst)
+	}
+
 	fn poll(dur: Duration) -> anyhow::Result<Option<Event>> {
 		if event::poll(dur)? {
 			Ok(Some(event::read()?))