From 5b7b35ea3ad3901a495ff378b6bfdd7d64f2ed67 Mon Sep 17 00:00:00 2001
From: Runxi Yu
Date: Sun, 8 Mar 2026 02:30:36 +0800
Subject: internal/compress: Remove InputConsumed/Progress

---
 internal/compress/zlib/reader.go | 19 -------------------
 1 file changed, 19 deletions(-)

(limited to 'internal/compress/zlib/reader.go')

diff --git a/internal/compress/zlib/reader.go b/internal/compress/zlib/reader.go
index 1f6d4337..78df4f56 100644
--- a/internal/compress/zlib/reader.go
+++ b/internal/compress/zlib/reader.go
@@ -73,7 +73,6 @@ var readerPool = sync.Pool{
 type Reader struct {
 	r            flate.Reader
 	decompressor io.ReadCloser
-	progress     flate.InputProgress
 	digest       hash.Hash32
 	headerRead   uint64
 	trailerRead  uint64
@@ -163,24 +162,6 @@ func (z *Reader) Read(p []byte) (int, error) {
 	return n, io.EOF
 }
 
-// InputConsumed returns compressed bytes consumed from stream input.
-//
-// This count includes the zlib header, deflate payload, and zlib checksum
-// trailer bytes read by the reader.
-func (z *Reader) InputConsumed() uint64 {
-	out := z.headerRead + z.trailerRead
-	if z.progress != nil {
-		progressIn, err := intconv.Int64ToUint64(z.progress.InputConsumed())
-		if err != nil {
-			panic(err)
-		}
-
-		out += progressIn
-	}
-
-	return out
-}
-
 // 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].
-- 
cgit v1.3.1-10-gc9f91