summaryrefslogtreecommitdiff
path: root/pkg/server/hook/hex.go
diff options
context:
space:
mode:
authorMikhail Osipov <mike.osipov@gmail.com>2020-02-29 21:50:58 +0300
committerMikhail Osipov <mike.osipov@gmail.com>2020-02-29 23:48:53 +0300
commit8b7283ad01a8dde92cf708f81f6c1105647bafd7 (patch)
tree6598c17258bacb4e84f6e486e591460437e93086 /pkg/server/hook/hex.go
parent7ab641d239e502e09c6f05dfc7efd069fcf3c314 (diff)
close pipes at end of stream
Diffstat (limited to 'pkg/server/hook/hex.go')
-rw-r--r--pkg/server/hook/hex.go4
1 files changed, 2 insertions, 2 deletions
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())
}