1 files changed, 4 insertions, 0 deletions
diff --git a/mx_recv.go b/mx_recv.go
index ef8c2cc..33b4012 100644
--- a/mx_recv.go
+++ b/mx_recv.go
@@ -6,6 +6,7 @@ import (
 	"context"
 	"crypto/tls"
 	"errors"
+	"io"
 	"net"
 	"slices"
 	"strings"
@@ -49,6 +50,9 @@ func (session *mx_recv_session) handle(ctx context.Context) error {
 	for {
 		line, err := session.buf_conn.ReadString('\n')
 		if err != nil {
+			if err == io.EOF {
+				return err_connection_handler_eof
+			}
 			return err
 		}
 		line = strings.TrimSuffix(line, "\n")