From 8b7283ad01a8dde92cf708f81f6c1105647bafd7 Mon Sep 17 00:00:00 2001 From: Mikhail Osipov Date: Sat, 29 Feb 2020 21:50:58 +0300 Subject: close pipes at end of stream --- pkg/server/hook/zip.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'pkg/server/hook/zip.go') 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) { -- cgit v1.2.3-70-g09d2