diff --git a/input_file.go b/input_file.go index 3cbf2b1..ad2495c 100644 --- a/input_file.go +++ b/input_file.go @@ -58,8 +58,8 @@ func (i *FileInput) emit() { if lastTime != 0 { time.Sleep(time.Duration(raw.Timestamp - lastTime)) - lastTime = raw.Timestamp } + lastTime = raw.Timestamp i.data <- raw.Request }