async fn handle_connection( ws: WebSocketStream<TcpStream>, metrics: Arc<RwLock<AggregatedMetrics>>, interval_ms: u64, ) -> Result<()>