diff options
| author | Mikhail Osipov <mike.osipov@gmail.com> | 2020-02-29 21:50:58 +0300 |
|---|---|---|
| committer | Mikhail Osipov <mike.osipov@gmail.com> | 2020-02-29 23:48:53 +0300 |
| commit | 8b7283ad01a8dde92cf708f81f6c1105647bafd7 (patch) | |
| tree | 6598c17258bacb4e84f6e486e591460437e93086 /pkg/server/hook/hex.go | |
| parent | 7ab641d239e502e09c6f05dfc7efd069fcf3c314 (diff) | |
close pipes at end of stream
Diffstat (limited to 'pkg/server/hook/hex.go')
| -rw-r--r-- | pkg/server/hook/hex.go | 4 |
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()) } |
