close pipes at end of stream

1 files changed, 4 insertions, 4 deletions

diff --git a/pkg/server/hook/zip.go b/pkg/server/hook/zip.go
index 61264c9..94160fe 100644
--- a/pkg/server/hook/zip.go
+++ b/pkg/server/hook/zip.go
@@ -10,7 +10,7 @@ import (
 
 type zipHook struct{}
 
-func (m zipHook) Send(rq, wq queue.Q) error {
+func (zipHook) Send(rq, wq queue.Q) error {
 	w, err := flate.NewWriter(wq.Writer(), flate.BestCompression)
 	if err != nil {
 		return err
@@ -28,7 +28,7 @@ func (m zipHook) Send(rq, wq queue.Q) error {
 	return w.Close()
 }
 
-func (m zipHook) Recv(rq, wq queue.Q) error {
+func (zipHook) Recv(rq, wq queue.Q) error {
 	r := flate.NewReader(rq.Reader())
 
 	// FIXME: not received ending due to ultimate conn.Close
@@ -42,8 +42,8 @@ func (m zipHook) Recv(rq, wq queue.Q) error {
 	return r.Close()
 }
 
-func (m zipHook) Open(env.Env) (interface{}, error) {
-	return m, nil
+func (h zipHook) Open(env.Env) (interface{}, error) {
+	return h, nil
 }
 
 func newZipHook(opts.Opts, env.Env) (hook, error) {