diff options
Diffstat (limited to 'internal')
| -rw-r--r-- | internal/zlib/reader.go | 3 | ||||
| -rw-r--r-- | internal/zlib/reader_reset.go | 4 |
2 files changed, 4 insertions, 3 deletions
diff --git a/internal/zlib/reader.go b/internal/zlib/reader.go index 30e98cdb..c1e26aae 100644 --- a/internal/zlib/reader.go +++ b/internal/zlib/reader.go @@ -121,7 +121,7 @@ func NewReaderDict(r io.Reader, dict []byte) (*Reader, error) { panic("zlib: pool returned unexpected type") } - err := z.Reset(r, dict) + err := z.reset(r, dict) if err != nil { return nil, err } @@ -188,6 +188,7 @@ func (z *Reader) InputConsumed() uint64 { // Close does not close the wrapped [io.Reader] originally passed to [NewReader]. // In order for the ZLIB checksum to be verified, the reader must be // fully consumed until the [io.EOF]. +// Close returns the instance to a global pool; you MUST NOT keep references after Close. func (z *Reader) Close() error { if z.err != nil && !errors.Is(z.err, io.EOF) { return z.err diff --git a/internal/zlib/reader_reset.go b/internal/zlib/reader_reset.go index 6f15b681..4d9d4471 100644 --- a/internal/zlib/reader_reset.go +++ b/internal/zlib/reader_reset.go @@ -15,8 +15,8 @@ import ( "github.com/klauspost/compress/flate" ) -// Reset resets receiver to read a new zlib stream. -func (z *Reader) Reset(r io.Reader, dict []byte) error { +// reset resets receiver to read a new zlib stream. +func (z *Reader) reset(r io.Reader, dict []byte) error { *z = Reader{decompressor: z.decompressor} var input flate.Reader if fr, ok := r.(flate.Reader); ok { |