@@ -9,7 +9,6 @@ use std::cmp::max;
9
9
use std:: path:: PathBuf ;
10
10
use std:: sync:: mpsc:: { Receiver , Sender } ;
11
11
use std:: sync:: { mpsc, Arc , RwLock } ;
12
- use std:: time:: Duration ;
13
12
use std:: { env, thread} ;
14
13
15
14
use crate :: data:: { DataContainer , Packet } ;
@@ -65,14 +64,14 @@ fn main_thread(
65
64
let mut file_opened = false ;
66
65
67
66
loop {
68
- if let Ok ( cl) = clear_rx. recv_timeout ( Duration :: from_millis ( 1 ) ) {
67
+ if let Ok ( cl) = clear_rx. try_recv ( ) {
69
68
if cl {
70
69
data = DataContainer :: default ( ) ;
71
70
failed_format_counter = 0 ;
72
71
}
73
72
}
74
73
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 ( ) {
76
75
data. loaded_from_file = false ;
77
76
if !packet. payload . is_empty ( ) {
78
77
sync_tx. send ( true ) . expect ( "unable to send sync tx" ) ;
@@ -104,7 +103,7 @@ fn main_thread(
104
103
}
105
104
}
106
105
}
107
- if let Ok ( fp) = load_rx. recv_timeout ( Duration :: from_millis ( 10 ) ) {
106
+ if let Ok ( fp) = load_rx. try_recv ( ) {
108
107
if let Some ( file_ending) = fp. extension ( ) {
109
108
match file_ending. to_str ( ) . unwrap ( ) {
110
109
"csv" => {
@@ -145,7 +144,7 @@ fn main_thread(
145
144
* write_guard = data. clone ( ) ;
146
145
}
147
146
148
- if let Ok ( csv_options) = save_rx. recv_timeout ( Duration :: from_millis ( 1 ) ) {
147
+ if let Ok ( csv_options) = save_rx. try_recv ( ) {
149
148
match save_to_csv ( & data, & csv_options) {
150
149
Ok ( _) => {
151
150
log:: info!( "saved data file to {:?} " , csv_options. file_path) ;
0 commit comments