From 32201cacda48800ed317c0d0e1b52a1aec049862 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E4=B8=96=E7=95=8C?= <i@sekai.icu>
Date: Thu, 4 Aug 2022 00:00:07 +0800
Subject: [PATCH] Add unsafe tag to multiplexer writer

---
 common/mux/protocol.go | 7 +++++++
 1 file changed, 7 insertions(+)

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: