@@ -9,7 +9,6 @@ use std::cmp::max;
99use std:: path:: PathBuf ;
1010use std:: sync:: mpsc:: { Receiver , Sender } ;
1111use std:: sync:: { mpsc, Arc , RwLock } ;
12- use std:: time:: Duration ;
1312use std:: { env, thread} ;
1413
1514use crate :: data:: { DataContainer , Packet } ;
@@ -65,14 +64,14 @@ fn main_thread(
6564 let mut file_opened = false ;
6665
6766 loop {
68- if let Ok ( cl) = clear_rx. recv_timeout ( Duration :: from_millis ( 1 ) ) {
67+ if let Ok ( cl) = clear_rx. try_recv ( ) {
6968 if cl {
7069 data = DataContainer :: default ( ) ;
7170 failed_format_counter = 0 ;
7271 }
7372 }
7473 if !file_opened {
75- if let Ok ( packet) = raw_data_rx. recv_timeout ( Duration :: from_millis ( 1 ) ) {
74+ if let Ok ( packet) = raw_data_rx. try_recv ( ) {
7675 data. loaded_from_file = false ;
7776 if !packet. payload . is_empty ( ) {
7877 sync_tx. send ( true ) . expect ( "unable to send sync tx" ) ;
@@ -104,7 +103,7 @@ fn main_thread(
104103 }
105104 }
106105 }
107- if let Ok ( fp) = load_rx. recv_timeout ( Duration :: from_millis ( 10 ) ) {
106+ if let Ok ( fp) = load_rx. try_recv ( ) {
108107 if let Some ( file_ending) = fp. extension ( ) {
109108 match file_ending. to_str ( ) . unwrap ( ) {
110109 "csv" => {
@@ -145,7 +144,7 @@ fn main_thread(
145144 * write_guard = data. clone ( ) ;
146145 }
147146
148- if let Ok ( csv_options) = save_rx. recv_timeout ( Duration :: from_millis ( 1 ) ) {
147+ if let Ok ( csv_options) = save_rx. try_recv ( ) {
149148 match save_to_csv ( & data, & csv_options) {
150149 Ok ( _) => {
151150 log:: info!( "saved data file to {:?} " , csv_options. file_path) ;
0 commit comments