Fix bug in CompressWithGzip

Propagate io.Copy errors through the io.Pipe
influxdata · Oct 5, 2018 · 11cdf77 · 11cdf77
1 parent 1e0a10a
commit 11cdf77
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/internal/internal.go b/internal/internal.go
@@ -223,7 +223,9 @@ func CompressWithGzip(data io.Reader) (io.Reader, error) {
 	go func() {
 		_, err = io.Copy(gzipWriter, data)
 		gzipWriter.Close()
-		pipeWriter.Close()
+		// subsequent reads from the read half of the pipe will
+		// return no bytes and the error err, or EOF if err is nil.
+		pipeWriter.CloseWithError(err)
 	}()
 
 	return pipeReader, err