minor fix

Signed-off-by: Bugen Zhao <[email protected]>
risingwavelabs · Jul 10, 2024 · 8de79d9 · 8de79d9
1 parent 9ac49fd
commit 8de79d9
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/src/meta/src/rpc/election/dummy.rs b/src/meta/src/rpc/election/dummy.rs
@@ -50,10 +50,8 @@ impl ElectionClient for DummyElectionClient {
     }
 
     async fn run_once(&self, _ttl: i64, mut stop: Receiver<()>) -> MetaResult<()> {
-        tokio::select! {
-            _ = stop.changed() => {}
-            _ = futures::future::pending::<()>() => {}
-        }
+        // Only exit when the stop signal is received.
+        let _ = stop.changed().await;
         Ok(())
     }