diff --git a/h2mux_conn.go b/h2mux_conn.go
index 293e3a5..31c3286 100644
--- a/h2mux_conn.go
+++ b/h2mux_conn.go
@@ -8,6 +8,7 @@ import (
 
 	"github.com/sagernet/sing/common"
 	"github.com/sagernet/sing/common/baderror"
+	M "github.com/sagernet/sing/common/metadata"
 )
 
 type httpConn struct {
@@ -58,11 +59,11 @@ func (c *httpConn) Close() error {
 }
 
 func (c *httpConn) LocalAddr() net.Addr {
-	return nil
+	return M.Socksaddr{}
 }
 
 func (c *httpConn) RemoteAddr() net.Addr {
-	return nil
+	return M.Socksaddr{}
 }
 
 func (c *httpConn) SetDeadline(t time.Time) error {
diff --git a/session.go b/session.go
index 2e674c8..2dc37b3 100644
--- a/session.go
+++ b/session.go
@@ -3,6 +3,7 @@ package mux
 import (
 	"io"
 	"net"
+	"reflect"
 
 	E "github.com/sagernet/sing/common/exceptions"
 	"github.com/sagernet/smux"
@@ -34,6 +35,7 @@ func newClientSession(conn net.Conn, protocol byte) (abstractSession, error) {
 		}
 		return &smuxSession{client}, nil
 	case ProtocolYAMux:
+		checkYAMuxConn(conn)
 		client, err := yamux.Client(conn, yaMuxConfig())
 		if err != nil {
 			return nil, err
@@ -55,6 +57,7 @@ func newServerSession(conn net.Conn, protocol byte) (abstractSession, error) {
 		}
 		return &smuxSession{client}, nil
 	case ProtocolYAMux:
+		checkYAMuxConn(conn)
 		client, err := yamux.Server(conn, yaMuxConfig())
 		if err != nil {
 			return nil, err
@@ -65,6 +68,12 @@ func newServerSession(conn net.Conn, protocol byte) (abstractSession, error) {
 	}
 }
 
+func checkYAMuxConn(conn net.Conn) {
+	if conn.LocalAddr() == nil || conn.RemoteAddr() == nil {
+		panic("found net.Conn with nil addr: " + reflect.TypeOf(conn).String())
+	}
+}
+
 var _ abstractSession = (*smuxSession)(nil)
 
 type smuxSession struct {