feat: dispatch proxy error

client.go

@@ -117,7 +117,9 @@ func (c *Client) handleProxyRequest(ctx context.Context, m *control.Message) (*c
 		return nil, errors.WithStack(err)
 	}
 
-	pipe(stream, net)
+	if err := pipe(stream, net); err != nil {
+		return nil, errors.WithStack(err)
+	}
 
 	return nil, nil
 }

helper.go

@@ -5,22 +5,29 @@ import (
 	"net"
 )
 
-func pipe(client net.Conn, server net.Conn) {
+func pipe(client net.Conn, server net.Conn) (err error) {
 	stop := make(chan bool)
 
-	go relay(client, server, stop)
+	go func() {
-	go relay(server, client, stop)
+		err = relay(client, server, stop)
+	}()
+	go func() {
+		err = relay(server, client, stop)
+	}()
 
 	select {
 	case <-stop:
-		return
+		return err
 	}
 }
 
-func relay(src net.Conn, dst net.Conn, stop chan bool) {
+func relay(src io.ReadCloser, dst io.WriteCloser, stop chan bool) (err error) {
-	io.Copy(dst, src)
+	_, err = io.Copy(dst, src)
+
 	dst.Close()
 	src.Close()
+
 	stop <- true
+
 	return
 }