|
|
@ -446,11 +446,11 @@ func (c *Client) handlerTextMessage(b []byte) error {
|
|
|
|
if err != nil {
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
c.w.Lock()
|
|
|
|
|
|
|
|
defer c.w.Unlock()
|
|
|
|
if err := c.conn.SetWriteDeadline(writeWait); err != nil {
|
|
|
|
if err := c.conn.SetWriteDeadline(writeWait); err != nil {
|
|
|
|
return err
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
}
|
|
|
|
c.w.Lock()
|
|
|
|
|
|
|
|
defer c.w.Unlock()
|
|
|
|
|
|
|
|
return c.conn.WriteMessage(MessageText, msgData)
|
|
|
|
return c.conn.WriteMessage(MessageText, msgData)
|
|
|
|
default:
|
|
|
|
default:
|
|
|
|
return fmt.Errorf("not support message type %s", msg.Type)
|
|
|
|
return fmt.Errorf("not support message type %s", msg.Type)
|
|
|
|