diff --git a/input_file.go b/input_file.go index 37e2b6a..6dfffc4 100644 --- a/input_file.go +++ b/input_file.go @@ -230,6 +230,7 @@ func (i *FileInput) Close() error { i.exit <- true + for _, r := range i.readers { r.Close() }