mirror of
https://github.com/LibreQoE/LibreQoS.git
synced 2025-02-25 18:55:32 -06:00
Cleaner handler for single user channel socket cleanup
This commit is contained in:
parent
50042d79ea
commit
a649ea8639
@ -62,25 +62,19 @@ async fn handle_socket(mut socket: WebSocket) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
Some(Err(e)) => {
|
Some(Err(_)) => break,
|
||||||
log::warn!("Error receiving websocket message: {:?}", e);
|
None => break,
|
||||||
break;
|
|
||||||
}
|
|
||||||
None => {
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
outbound = rx.recv() => {
|
outbound = rx.recv() => {
|
||||||
match outbound {
|
match outbound {
|
||||||
Some(msg) => {
|
Some(msg) => {
|
||||||
socket.send(Message::Text(msg)).await.unwrap();
|
if let Err(_) = socket.send(Message::Text(msg)).await {
|
||||||
}
|
|
||||||
None => {
|
|
||||||
log::info!("WebSocket Disconnected");
|
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
None => break,
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user