fix compression test error
Signed-off-by: xiaolong.ran <ranxiaolong716@gmail.com>
diff --git a/pkg/compression/lz4.go b/pkg/compression/lz4.go
index 449c205..b391336 100644
--- a/pkg/compression/lz4.go
+++ b/pkg/compression/lz4.go
@@ -21,8 +21,7 @@
"github.com/pierrec/lz4"
)
-type lz4Provider struct {
-}
+type lz4Provider struct {}
// NewLz4Provider return a interface of Provider.
func NewLz4Provider() Provider {
diff --git a/pkg/compression/zlib.go b/pkg/compression/zlib.go
index f1c1b91..4c3fba8 100644
--- a/pkg/compression/zlib.go
+++ b/pkg/compression/zlib.go
@@ -36,14 +36,8 @@
func (zlibProvider) Compress(data []byte) []byte {
var b bytes.Buffer
w := zlib.NewWriter(&b)
- _, err := w.Write(data)
- if err != nil {
- return nil
- }
- err = w.Close()
- if err != nil {
- return nil
- }
+ w.Write(data)
+ w.Close()
return b.Bytes()
}
@@ -55,14 +49,8 @@
}
uncompressed := make([]byte, originalSize)
- _, err = r.Read(uncompressed)
- if err != nil {
- return nil, err
- }
- err = r.Close()
- if err != nil {
- return nil, err
- }
+ r.Read(uncompressed)
+ r.Close()
return uncompressed, nil
}
