diff --git a/src/bin/server.rs b/src/bin/server.rs index 5fc4bcf..3ce6cfe 100644 --- a/src/bin/server.rs +++ b/src/bin/server.rs @@ -183,11 +183,9 @@ async fn main() { let updater_tx = request_tx.clone(); let shutdown_cmd_tx = request_tx.clone(); - // create the shutdown broadcast channel and clone for every thread + // create the shutdown broadcast channel let (shutdown_tx, mut shutdown_rx) = broadcast::channel(16); let kill = shutdown_tx.subscribe(); - // TODO: Gracefully shut down updater - let kill_updater = shutdown_tx.subscribe(); // Listen for ctrl_c, send signal to broadcast shutdown to all threads by dropping shutdown_tx let shutdown_handler = spawn(async move {