IndexerService should use is_cancelled() to check if ckb received c…

…trl-c signal
nervosnetwork · Feb 18, 2024 · fd6987d · fd6987d
1 parent 36f5b22
commit fd6987d
Showing 1 changed file with 3 additions and 7 deletions.
diff --git a/util/indexer/src/service.rs b/util/indexer/src/service.rs
@@ -238,13 +238,9 @@ impl IndexerService {
         self.async_handle.spawn(async move {
             let _initial_finished = initial_syncing.await;
             info!("initial_syncing finished");
-
-            tokio::select! {
-                _ = stop.cancelled() => {
-                    info!("Indexer received exit signal, cancel new_block_watcher task, exit now");
-                    return;
-                },
-                else => {},
+            if stop.is_cancelled() {
+                info!("Indexer received exit signal, cancel new_block_watcher task, exit now");
+                return;
             }
 
             let mut new_block_watcher = notify_controller