Log stream close errors

ntex-rs · Aug 30, 2024 · 11c01a5 · 11c01a5
1 parent fac6ecb
commit 11c01a5
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/ntex-compio/src/io.rs b/ntex-compio/src/io.rs
@@ -15,8 +15,10 @@ impl IoStream for crate::TcpStream {
         compio::runtime::spawn(async move {
             run(&mut io, &read, write).await;
 
-            let res = io.close().await;
-            log::debug!("{} Stream is closed, {:?}", read.tag(), res);
+            match io.close().await {
+                Ok(_) => log::debug!("{} Stream is closed", read.tag()),
+                Err(e) => log::error!("{} Stream is closed, {:?}", read.tag(), e),
+            }
         })
         .detach();
 
@@ -31,8 +33,10 @@ impl IoStream for crate::UnixStream {
         compio::runtime::spawn(async move {
             run(&mut io, &read, write).await;
 
-            let res = io.close().await;
-            log::debug!("{} Stream is closed, {:?}", read.tag(), res);
+            match io.close().await {
+                Ok(_) => log::debug!("{} Unix stream is closed", read.tag()),
+                Err(e) => log::error!("{} Unix stream is closed, {:?}", read.tag(), e),
+            }
         })
         .detach();