_/cri
1
0
Fork 0
Code Issues 16 Pull requests Projects Releases Packages Wiki Activity

Fix crash after some while

Browse source
This commit is contained in:
Sijmen 2023-11-23 11:45:55 +01:00
parent 603f4c96e2
commit 7fd71c8f07
Signed by: vijfhoek
GPG key ID: DAF7821E067D9C48
1 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/irc_handler.rs
View file

@ -34,15 +34,16 @@ pub async fn message_loop(
loop { loop {
select! { select! {
val = irc_stream.next() => { val = irc_stream.next() => {
if let Some(message) = val.transpose()? { if let Some(Ok(message)) = val {
println!("[Rx] {}", message.to_string().trim()); println!("[Rx] {}", message.to_string().trim());
message_tx.send(message)?; message_tx.send(message)?;
} }
} }
val = input_rx.recv() => { val = input_rx.recv() => {
let message = val.unwrap(); if let Some(message) = val {
println!("[Tx] {}", message.to_string().trim()); println!("[Tx] {}", message.to_string().trim());
client.send(message)?; client.send(message)?;
}
} }
} }
} }