wait_until_i_am_the_last_task() - num_alive should be 0, not 1

crates/librqbit/src/tests/e2e.rs

@@ -23,6 +23,8 @@ use crate::{
 
 #[tokio::test(flavor = "multi_thread", worker_threads = 64)]
 async fn test_e2e_download() {
+    wait_until_i_am_the_last_task().await.unwrap();
+
     let timeout = std::env::var("E2E_TIMEOUT")
         .ok()
         .and_then(|v| v.parse().ok())
@@ -38,7 +40,7 @@ async fn test_e2e_download() {
     .unwrap();
 
     // Wait to ensure everything is dropped.
-    wait_until_i_am_the_last_task().await;
+    wait_until_i_am_the_last_task().await.unwrap();
 
     drop_checks.check().unwrap();
 }

crates/librqbit/src/tests/test_util.rs

@@ -196,19 +196,18 @@ pub async fn wait_until(
     Ok(())
 }
 
-pub async fn wait_until_i_am_the_last_task() {
+pub async fn wait_until_i_am_the_last_task() -> anyhow::Result<()> {
     let metrics = tokio::runtime::Handle::current().metrics();
     wait_until(
         || {
             let num_alive = metrics.num_alive_tasks();
-            if num_alive != 1 {
-                bail!("metrics.num_alive_tasks() = {num_alive}, expected 1")
+            if num_alive != 0 {
+                bail!("metrics.num_alive_tasks() = {num_alive}, expected 0")
             }
             Ok(())
         },
         // This needs to be higher than the timeout the tasks print "still running"
         Duration::from_secs(6),
     )
     .await
-    .unwrap();
 }