fix sleep print

pankajsoni19 · Jan 17, 2025 · d854ae5 · d854ae5
1 parent dba3813
commit d854ae5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/manager/pipe.go b/internal/manager/pipe.go
@@ -143,7 +143,7 @@ func (p *pipe) NextSubscribers(result chan *NextSubResult) {
 					p.slidingCount,
 					p.SlidingWindowDuration,
 					p.slidingStart.Format(time.RFC822Z),
-					time.Second)
+					wait)
 
 				p.slidingCount = 0
 				p.pauseFor(wait)