From 0a4a4787cd547d56caa1f6e482f42c57789c3908 Mon Sep 17 00:00:00 2001
From: lesismal <lesismal@gmail.com>
Date: Mon, 30 May 2022 21:02:56 +0800
Subject: [PATCH] ci: fix test

---
 client.go  | 10 ++++------
 handler.go |  2 +-
 2 files changed, 5 insertions(+), 7 deletions(-)

diff --git a/client.go b/client.go
index b916c32..09de2ef 100644
--- a/client.go
+++ b/client.go
@@ -463,13 +463,11 @@ func (c *Client) Restart() error {
 
 // Stop stops a Client.
 func (c *Client) Stop() {
-	c.Handler.AsyncExecute(func() {
-		c.mux.Lock()
-		c.running = false
-		c.mux.Unlock()
+	c.mux.Lock()
+	c.running = false
+	c.mux.Unlock()
 
-		c.Conn.Close()
-	})
+	c.Conn.Close()
 }
 
 func (c *Client) closeAndClean() {
diff --git a/handler.go b/handler.go
index c6234a9..2b36e75 100644
--- a/handler.go
+++ b/handler.go
@@ -653,7 +653,7 @@ func (h *handler) OnMessage(c *Client, msg *Message) {
 		}
 	default:
 		log.Warn("%v OnMessage: invalid cmd [%v]", h.LogTag(), msg.Cmd())
-		c.Stop()
+		go c.Stop()
 	}
 }