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/hex.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'pkg/server/hook/hex.go') diff --git a/pkg/server/hook/hex.go b/pkg/server/hook/hex.go index beaadeb..e37bc6e 100644 --- a/pkg/server/hook/hex.go +++ b/pkg/server/hook/hex.go @@ -9,7 +9,7 @@ import ( type hexHook struct{} -func (h hexHook) Send(rq, wq queue.Q) error { +func (hexHook) Send(rq, wq queue.Q) error { enc := hex.NewEncoder(wq.Writer()) for b := range rq { @@ -19,7 +19,7 @@ func (h hexHook) Send(rq, wq queue.Q) error { return nil } -func (h hexHook) Recv(rq, wq queue.Q) error { +func (hexHook) Recv(rq, wq queue.Q) error { r := hex.NewDecoder(rq.Reader()) return queue.IoCopy(r, wq.Writer()) } -- cgit v1.2.3-70-g09d2