From 15619fc89001f8c95c8426052e4f2a483cbfcab8 Mon Sep 17 00:00:00 2001
From: Ken Hibino <ken.hibino7@gmail.com>
Date: Sun, 6 Mar 2022 07:46:34 -0800
Subject: [PATCH] Update forwarder to use time.Timer

---
 forwarder.go | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/forwarder.go b/forwarder.go
index 0d65f5c..40bb4ef 100644
--- a/forwarder.go
+++ b/forwarder.go
@@ -56,13 +56,15 @@ func (f *forwarder) start(wg *sync.WaitGroup) {
 	wg.Add(1)
 	go func() {
 		defer wg.Done()
+		timer := time.NewTimer(f.avgInterval)
 		for {
 			select {
 			case <-f.done:
 				f.logger.Debug("Forwarder done")
 				return
-			case <-time.After(f.avgInterval):
+			case <-timer.C:
 				f.exec()
+				timer.Reset(f.avgInterval)
 			}
 		}
 	}()