dont panic if message fails to send

This commit is contained in:
Jade Rowland 2023-09-04 17:07:50 -04:00
parent a9d8e7ca82
commit d233d50de3

View File

@ -58,14 +58,15 @@ pub fn init(
/* ........................................................... /* ...........................................................
Process queued messages Process queued messages
............................................................*/ ............................................................*/
let mut prev_time = Instant::now();
loop { loop {
let mut message_queue = message_queue_clone.lock().await; let mut message_queue = message_queue_clone.lock().await;
message_queue.retain(|message| { message_queue.retain(|message| {
sock.send(&message.msg_buf).unwrap(); let result = sock.send(&message.msg_buf);
prev_time = Instant::now(); if result.is_err() {
println!("OSC Message failed to send, the server might no longer be available");
}
return false; return false;
}); });