|
@@ -193,7 +193,7 @@ func DecompressStream(archive io.Reader) (io.ReadCloser, error) {
|
|
}
|
|
}
|
|
|
|
|
|
// CompressStream compresses the dest with specified compression algorithm.
|
|
// CompressStream compresses the dest with specified compression algorithm.
|
|
-func CompressStream(dest io.WriteCloser, compression Compression) (io.WriteCloser, error) {
|
|
|
|
|
|
+func CompressStream(dest io.Writer, compression Compression) (io.WriteCloser, error) {
|
|
p := pools.BufioWriter32KPool
|
|
p := pools.BufioWriter32KPool
|
|
buf := p.Get(dest)
|
|
buf := p.Get(dest)
|
|
switch compression {
|
|
switch compression {
|