add a yield_now just in case

Cargo.lock

@@ -1298,7 +1298,7 @@ dependencies = [
 
 [[package]]
 name = "deduped_broadcast"
-version = "0.2.0"
+version = "0.2.1"
 dependencies = [
  "lru",
  "serde",

deduped_broadcast/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "deduped_broadcast"
-version = "0.2.0"
+version = "0.2.1"
 edition = "2021"
 
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html

deduped_broadcast/src/lib.rs

@@ -8,6 +8,7 @@ use std::{
     hash::{Hash, Hasher},
 };
 use tokio::sync::{broadcast, mpsc};
+use tokio::task::yield_now;
 
 struct DedupedBroadcasterTask<T>
 where
@@ -58,6 +59,8 @@ where
                     self.total_broadcasts.fetch_add(x, Ordering::Relaxed);
                 }
             });
+
+            yield_now().await;
         }
     }
 }