Code cleanup: rename CompressedOutputStream/CompressedInputStream res…

…pectively Writer and Reader. Improve documentation
flanglet · Dec 7, 2023 · fe87adf · fe87adf
1 parent a0559b9
commit fe87adf
Show file tree

Hide file tree

Showing 4 changed files with 102 additions and 97 deletions.
diff --git a/v2/app/BlockCompressor.go b/v2/app/BlockCompressor.go
@@ -750,7 +750,7 @@ func (this *fileCompressTask) call() (int, uint64, uint64) {
 
 	}
 
-	cos, err := kio.NewCompressedOutputStreamWithCtx(output, this.ctx)
+	cos, err := kio.NewWriterWithCtx(output, this.ctx)
 
 	if err != nil {
 		if ioerr, isIOErr := err.(kio.IOError); isIOErr == true {

diff --git a/v2/app/BlockDecompressor.go b/v2/app/BlockDecompressor.go
@@ -574,7 +574,7 @@ func (this *fileDecompressTask) call() (int, uint64) {
 		}()
 	}
 
-	cis, err := kio.NewCompressedInputStreamWithCtx(input, this.ctx)
+	cis, err := kio.NewReaderWithCtx(input, this.ctx)
 
 	if err != nil {
 		if err.(*kio.IOError) != nil {