diff --git a/ws/wsClient.go b/ws/wsClient.go index dfaacd9..43e3570 100644 --- a/ws/wsClient.go +++ b/ws/wsClient.go @@ -110,11 +110,11 @@ func (c *Client) writeLoop() { case msg := <-c.sendChan: switch msg.messageType { case websocket.PingMessage: - log.Debug(c.Log("send ping message")) + //log.Debug(c.Log("send ping message")) _ = c.conn.WriteMessage(websocket.PingMessage, []byte("ping")) - case websocket.PongMessage: - log.Debug(c.Log("send pong message")) - _ = c.conn.WriteMessage(websocket.PongMessage, []byte("pong")) + //case websocket.PongMessage: + // log.Debug(c.Log("send pong message")) + // _ = c.conn.WriteMessage(websocket.PongMessage, []byte("pong")) default: _ = c.conn.WriteMessage(msg.messageType, msg.data) } diff --git a/ws/ws_test.go b/ws/ws_test.go index 1ade146..c2c11bd 100644 --- a/ws/ws_test.go +++ b/ws/ws_test.go @@ -40,7 +40,7 @@ func wsClient() { log.Fatal(err.Error()) return } - defer client.Stop() + defer client.WaitStop() count := 1 client.Start()