From d56c8fd52a610318313f66cf0f1b519fc8022ba7 Mon Sep 17 00:00:00 2001
From: sxyazi <sxyazi@gmail.com>
Date: Tue, 10 Oct 2023 18:14:28 +0800
Subject: [PATCH] fix: temporarily cancel the delay prepared for batch updates

---
 core/src/manager/watcher.rs | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/core/src/manager/watcher.rs b/core/src/manager/watcher.rs
index d7538095..45b34190 100644
--- 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 {