dynamic-sink

nikolaydubina · Feb 22, 2024 · 1a32a96 · 1a32a96
1 parent 2af0d69
commit 1a32a96
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 5 deletions.
diff --git a/aws_s3_reader_seeker.go b/aws_s3_reader_seeker.go
@@ -44,15 +44,13 @@ func NewS3ReadSeeker(
 	s3client *s3.S3,
 	bucket string,
 	key string,
-	minChunkSize int,
 	chunkSizePolicy ChunkSizePolicy,
 ) *S3ReadSeeker {
 	return &S3ReadSeeker{
 		s3client:        s3client,
 		bucket:          bucket,
 		key:             key,
 		chunkSizePolicy: chunkSizePolicy,
-		sink:            make([]byte, minChunkSize),
 	}
 }
 

diff --git a/aws_s3_reader_seeker_test.go b/aws_s3_reader_seeker_test.go
@@ -26,7 +26,6 @@ func TestS3ReadSeeker(t *testing.T) {
 		s3client,
 		bucket,
 		key,
-		1<<10*100,
 		awss3reader.FixedChunkSizePolicy{Size: 1 << 10 * 100}, // 100 KB
 	)
 	defer r.Close()
@@ -76,7 +75,6 @@ func TestS3ReadSeeker_SeekLarge(t *testing.T) {
 		s3client,
 		bucket,
 		key,
-		1<<10*100,
 		awss3reader.FixedChunkSizePolicy{Size: 1 << 10 * 100}, // 100 KB
 	)
 	defer r.Close()
@@ -131,7 +129,6 @@ func TestS3ReadSeeker_SeekDiscardHTTPBody(t *testing.T) {
 		s3client,
 		bucket,
 		key,
-		1<<10*100,
 		awss3reader.FixedChunkSizePolicy{Size: 1 << 10 * 100}, // 100 KB
 	)
 	defer r.Close()