YGGverse/aquatic
1
0
Fork 0
mirror of https://github.com/YGGverse/aquatic.git synced 2026-03-31 17:55:36 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

ws socket worker: replace unwrap with error return

Browse source
This commit is contained in:
Joakim Frostegård 2023-01-03 18:27:56 +01:00
parent 8bf0e12cb4
commit 14a801f4d4
1 changed files with 5 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

6
aquatic_ws/src/workers/socket.rs
View file

@ -455,7 +455,11 @@ impl<S: futures::AsyncRead + futures::AsyncWrite + Unpin> ConnectionReader<S> {
yield_if_needed().await; yield_if_needed().await;
} }
let message = self.ws_in.next().await.unwrap()?; let message = self
.ws_in
.next()
.await
.ok_or_else(|| anyhow::anyhow!("Stream ended"))??;
match InMessage::from_ws_message(message) { match InMessage::from_ws_message(message) {
Ok(in_message) => { Ok(in_message) => {