diff options
| -rw-r--r-- | pkg/server/tunnel.go | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/pkg/server/tunnel.go b/pkg/server/tunnel.go index f29a2f3..49f684e 100644 --- a/pkg/server/tunnel.go +++ b/pkg/server/tunnel.go @@ -1,7 +1,9 @@ package server import ( + "errors" "fmt" + "io" "log" "sort" "strings" @@ -161,7 +163,7 @@ func (s *stream) channel(c socket.Channel, rq, wq queue.Q) { watch := func(q queue.Q, f func(q queue.Q) error) { defer s.wg.Done() - if err := f(q); err != nil { + if err := f(q); err != nil && !errors.Is(err, io.EOF) { log.Println(s.t, s, err) } } @@ -185,7 +187,7 @@ func (s *stream) pipe(m module.M, p module.Pipe, rq, wq queue.Q) { go func() { defer s.wg.Done() - if err := p(rq, wq); err != nil { + if err := p(rq, wq); err != nil && !errors.Is(err, io.EOF) { log.Println(s.t, s, m, err) } |