diff --git a/tailer/fswatcher/pollingFseventProducerLoop.go b/tailer/fswatcher/pollingFseventProducerLoop.go index 1d261afd..f2f26f08 100644 --- a/tailer/fswatcher/pollingFseventProducerLoop.go +++ b/tailer/fswatcher/pollingFseventProducerLoop.go @@ -35,7 +35,11 @@ func runPollLoop(pollInterval time.Duration) *pollloop { tick := time.After(pollInterval) select { case <-tick: - events <- struct{}{} + select { + case events <- struct{}{}: + case <-done: + return + } case <-done: return }