fix: temporarily cancel the delay prepared for batch updates

sxyazi · Oct 10, 2023 · d56c8fd · d56c8fd
1 parent 5d9b547
commit d56c8fd
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/core/src/manager/watcher.rs b/core/src/manager/watcher.rs
@@ -131,7 +131,10 @@ impl Watcher {
 	}
 
 	async fn changed(rx: UnboundedReceiver<Url>, watched: Arc<RwLock<IndexMap<Url, Option<Url>>>>) {
-		let rx = UnboundedReceiverStream::new(rx).chunks_timeout(100, Duration::from_millis(200));
+		// TODO: revert this once a new notification is implemented
+		// let rx = UnboundedReceiverStream::new(rx).chunks_timeout(100,
+		// Duration::from_millis(200));
+		let rx = UnboundedReceiverStream::new(rx).chunks_timeout(1, Duration::ZERO);
 		pin!(rx);
 
 		while let Some(urls) = rx.next().await {