reduce filter loop to 300ms

status-im · Aug 26, 2024 · 4a18c85 · 4a18c85
1 parent f958925
commit 4a18c85
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/wakuv2/filter_manager.go b/wakuv2/filter_manager.go
@@ -67,7 +67,7 @@ func newFilterManager(ctx context.Context, logger *zap.Logger, cfg *Config, onNe
 	mgr.node = node
 	mgr.onlineChecker = onlinechecker.NewDefaultOnlineChecker(false).(*onlinechecker.DefaultOnlineChecker)
 	mgr.node.SetOnlineChecker(mgr.onlineChecker)
-	mgr.filterSubBatchDuration = 5 * time.Second
+	mgr.filterSubBatchDuration = 300 * time.Millisecond
 	mgr.incompleteFilterBatch = make(map[string]filterConfig)
 	mgr.filterConfigs = make(appFilterMap)
 	mgr.waitingToSubQueue = make(chan filterConfig, 100)