|
|
@@ -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 {
|