fixes a hang that occurs when no matching streams are found: (#21)

segmentio · Aug 8, 2017 · 8bc25b1 · 8bc25b1
1 parent b2145d7
commit 8bc25b1
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/lib/cwreader.go b/lib/cwreader.go
@@ -96,6 +96,7 @@ func (c *CloudwatchLogsReader) pumpEvents(eventChan chan<- Event, follow bool) {
 		streams, err := c.getLogStreams()
 		if err != nil {
 			c.error = err
+			close(eventChan)
 			return
 		}
 		params.LogStreamNames = streamsToNames(streams)