changed to time.NewTicker

kubesure · May 20, 2022 · cb61dcb · cb61dcb
1 parent e62baa5
commit cb61dcb
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/dispatch.go b/dispatch.go
@@ -22,7 +22,7 @@ func dispatch(ctx context.Context, i input, w Worker, pulseInterval time.Duratio
 
 	go func() {
 		defer close(pulseStream)
-		pulse := time.Tick(pulseInterval)
+		pulse := time.NewTicker(pulseInterval)
 
 		sendPulse := func() {
 			select {
@@ -35,7 +35,7 @@ func dispatch(ctx context.Context, i input, w Worker, pulseInterval time.Duratio
 			select {
 			case <-quitPulstStream:
 				return
-			case <-pulse:
+			case <-pulse.C:
 				sendPulse()
 			}
 		}