VCC/vcs-common
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

more logging

Browse source
This commit is contained in:
Nickiel12 2024-08-20 20:30:25 -07:00
parent 5ef291bd5d
commit 8cab24104c
1 changed files with 3 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
src/lib.rs
View file

@ -86,6 +86,7 @@ pub async fn send_to_wc_task(
is_closed: Arc<AtomicBool>, is_closed: Arc<AtomicBool>,
mut sender: SplitSink<WebSocketStream<MaybeTlsStream<TcpStream>>, tokio_tungstenite::tungstenite::Message> mut sender: SplitSink<WebSocketStream<MaybeTlsStream<TcpStream>>, tokio_tungstenite::tungstenite::Message>
) { ) {
info!("From app is closed: {:?}", from_app.is_closed());
while let Ok(msg) = from_app.recv().await { while let Ok(msg) = from_app.recv().await {
#[cfg(debug_assertions)] #[cfg(debug_assertions)]
{ {
@ -131,6 +132,8 @@ pub async fn listen_to_ws_task(
mut reader: SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>> mut reader: SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>
){ ){
info!("To_app is closed: {:?}", to_app.is_closed());
while let Some(msg) = reader.next().await { while let Some(msg) = reader.next().await {
match msg { match msg {
Err(e) => { Err(e) => {