diff --git a/common/mux/protocol.go b/common/mux/protocol.go
index 8ffb5a8c..95baccb2 100644
--- a/common/mux/protocol.go
+++ b/common/mux/protocol.go
@@ -217,6 +217,13 @@ func (w *wrapStream) Write(p []byte) (n int, err error) {
 	return
 }
 
+func (w *wrapStream) WriteIsThreadUnsafe() {
+}
+
+func (w *wrapStream) Upstream() any {
+	return w.Conn
+}
+
 func wrapError(err error) error {
 	switch err {
 	case yamux.ErrStreamClosed: