updated monitoring socket

src/monitoring.rs

@@ -36,8 +36,18 @@ pub async fn apiserver(ctxarc: &Arc<RwLock<Context>>) -> io::Result<()> {
                         .write_all(format!("{data}\n").as_bytes())
                         .await
                         .unwrap();
-                    stream.flush().await.unwrap();
+                    match stream.flush().await {
-                    stream.shutdown().await.unwrap();
+                        Ok(_) => {}
+                        Err(e) => {
+                            println!("error flushing stream: {e}")
+                        }
+                    }
+                    match stream.shutdown().await {
+                        Ok(_) => {}
+                        Err(e) => {
+                            println!("error shuting down stream: {e}")
+                        }
+                    }
                 }
                 Err(err) => {
                     println!("unable to serialize data: {err}");