diff --git a/conn.go b/conn.go
index f3512eb..cb2dcb9 100644
--- a/conn.go
+++ b/conn.go
@@ -317,6 +317,9 @@ func (c *ServerConn) serve(s *ServerStream) {
 
 // Close close the server connection
 func (c *ServerConn) Close() error {
+	c.lock.Lock()
+	defer c.lock.Unlock()
+
 	if c.closed {
 		return nil
 	}