aboutsummaryrefslogtreecommitdiff
path: root/internal
diff options
context:
space:
mode:
authorGravatar Runxi Yu2026-03-05 17:29:54 +0800
committerGravatar Runxi Yu2026-03-05 17:54:19 +0800
commitfeebbc0c64e97b106fc021561086ad93e22d6006 (patch)
tree1489cbcf55aa4effda9a15bbcc3bf78393a71b1d /internal
parentinternal/zlib: Add counting flate reader (diff)
signatureNo signature
internal/zlib: Unexport Reset
Diffstat (limited to 'internal')
-rw-r--r--internal/zlib/reader.go3
-rw-r--r--internal/zlib/reader_reset.go4
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 {