remove one for add a new if

elastic · Sep 28, 2018 · 88f039f · 88f039f
1 parent 88e4a1f
commit 88f039f
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/journalbeat/input/input.go b/journalbeat/input/input.go
@@ -138,9 +138,10 @@ func (i *Input) publishAll(client beat.Client) {
 				select {
 				case <-i.done:
 					return
-				default:
-				}
-				for v := range c {
+				case v, ok := <-c:
+					if !ok {
+						return
+					}
 					out <- v
 				}
 			}