Removed redundant Reset() calls on bufio.Reader/bufio.Writer/gzipWriter/flateWriter before returning them to the pool, since Reset() is immediately called after these instances are obtained from pool

1 files changed, 4 insertions, 6 deletions

diff --git a/stream.go b/stream.go
index 2d9723a..377ff46 100644
--- a/stream.go
+++ b/stream.go
@@ -26,12 +26,11 @@ func NewStreamReader(sw StreamWriter) io.Reader {
 	pr, pw := io.Pipe()
 
 	var bw *bufio.Writer
-	bwv := streamWriterBufPool.Get()
-	if bwv == nil {
+	v := streamWriterBufPool.Get()
+	if v == nil {
 		bw = bufio.NewWriter(pw)
-		bwv = bw
 	} else {
-		bw = bwv.(*bufio.Writer)
+		bw = v.(*bufio.Writer)
 		bw.Reset(pw)
 	}
 
@@ -46,8 +45,7 @@ func NewStreamReader(sw StreamWriter) io.Reader {
 		bw.Flush()
 		pw.Close()
 
-		bw.Reset(nil)
-		streamWriterBufPool.Put(bwv)
+		streamWriterBufPool.Put(bw)
 	}()
 
 	return pr