|
|
@ -312,7 +312,7 @@ func (ws *WsServer) wsHandler(w http.ResponseWriter, r *http.Request) {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
client := ws.clientPool.Get().(*Client)
|
|
|
|
client := ws.clientPool.Get().(*Client)
|
|
|
|
client.ResetClient(connContext, wsLongConn, connContext.GetBackground(), compression, ws)
|
|
|
|
client.ResetClient(connContext, wsLongConn, connContext.GetBackground(), compression, ws, token)
|
|
|
|
ws.registerChan <- client
|
|
|
|
ws.registerChan <- client
|
|
|
|
go client.readMessage()
|
|
|
|
go client.readMessage()
|
|
|
|
}
|
|
|
|
}
|
|
|
|