Fix: monitor ticker

dipdup-io · Apr 6, 2022 · ef08e60 · ef08e60
1 parent 4ebcffb
commit ef08e60
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/node/monitor.go b/node/monitor.go
@@ -141,11 +141,14 @@ func (monitor *Monitor) pollingMempool(ctx context.Context, filter string) {
 
 	url := fmt.Sprintf("/chains/main/mempool/monitor_operations?%s", filter)
 
+	ticker := time.NewTicker(time.Second)
+	defer ticker.Stop()
+
 	for {
 		select {
 		case <-ctx.Done():
 			return
-		default:
+		case <-ticker.C:
 			if err := monitor.process(ctx, filter, url); err != nil {
 				log.Err(err).Msg("")
 				continue