fix poll loop close

fstab · Jun 24, 2019 · be0a033 · be0a033
1 parent 5060649
commit be0a033
Showing 1 changed file with 5 additions and 1 deletion.
diff --git 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
 			}