[server/tunnel] check EOF

TODO: replace queue.IoCopy with WriteTo/ReadFrom

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)
 		}