shiroyashik/sculptor
1
0
Fork 0
mirror of https://github.com/shiroyashik/sculptor.git synced 2025-12-06 13:01:12 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

use tracing_subscriber, handle subscription error

Browse source
This commit is contained in:
Cappy Ishihara 2024-06-02 03:21:58 +07:00
parent 026c6a950e
commit a5be9f187b
No known key found for this signature in database
GPG key ID: 50862C285CB76906
4 changed files with 156 additions and 25 deletions
Download patch file Download diff file Expand all files Collapse all files

19
src/ws/handler.rs
View file

@ -206,10 +206,21 @@ async fn subscribe(
return;
}
msg = rx.recv() => {
if socket.send(msg.unwrap()).await.is_err() {
error!("Forced shutdown SUB due error!");
return;
};
let msg = msg.ok();
if let Some(msg) = msg {
// debug!("[WebSocketSubscriber] Received: {msg}");
if socket.send(msg.clone()).await.is_err() {
error!("Forced shutdown SUB due error!");
return;
};
}
// if socket.send(msg.unwrap()).await.is_err() {
// error!("Forced shutdown SUB due error!");
// return;
// };
}
}
}