do not block on out channel if beat is stopped

elastic · Oct 16, 2018 · 2e11058 · 2e11058
1 parent b0becab
commit 2e11058
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/journalbeat/input/input.go b/journalbeat/input/input.go
@@ -178,7 +178,10 @@ func (i *Input) readEvents(wg *sync.WaitGroup, r *reader.Reader, out chan *beat.
 			continue
 		}
 
-		out <- event
+		select {
+		case <-i.done:
+		case out <- event:
+		}
 	}
 }