mirror of
https://github.com/m1k1o/neko.git
synced 2025-04-28 09:56:20 +02:00
websocket: fix unwrap err.
This commit is contained in:
parent
b783a9adbe
commit
6c5cd1260d
2 changed files with 6 additions and 2 deletions
|
@ -276,7 +276,9 @@ func (manager *WebSocketManagerCtx) connect(connection *websocket.Conn, r *http.
|
|||
|
||||
e, ok := err.(*websocket.CloseError)
|
||||
if !ok {
|
||||
err = errors.Unwrap(err) // unwrap if possible
|
||||
if e := errors.Unwrap(err); e != nil {
|
||||
err = e // unwrap if possible
|
||||
}
|
||||
logger.Warn().Err(err).Msg("read message error")
|
||||
// client is expected to reconnect soon
|
||||
delayedDisconnect = true
|
||||
|
|
|
@ -43,7 +43,9 @@ func (peer *WebSocketPeerCtx) Send(event string, payload any) {
|
|||
})
|
||||
|
||||
if err != nil {
|
||||
err = errors.Unwrap(err) // unwrap if possible
|
||||
if e := errors.Unwrap(err); e != nil {
|
||||
err = e // unwrap if possible
|
||||
}
|
||||
peer.logger.Warn().Err(err).Str("event", event).Msg("send message error")
|
||||
return
|
||||
}
|
||||
|
|
Loading…
Add table
Reference in a new issue