diff --git a/internal/manager/pipe.go b/internal/manager/pipe.go
index dee080d3a..31d9f23ff 100644
--- 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)