Compare commits

...

1 Commits

Author SHA1 Message Date
2ab2e07b9b fix: pong not sent 2025-10-01 14:00:22 +07:00

View File

@@ -324,19 +324,19 @@ func (wsClient *SafeWebsocketClient) connect() error {
}() }()
conn.SetPingHandler(func(pingData string) error { conn.SetPingHandler(func(pingData string) error {
wsClient.writeChan <- Message{ // wsClient.writeChan <- Message{
MessageType: MessageTypePong, // MessageType: MessageTypePong,
Data: []byte(pingData), // Data: []byte(pingData),
}
// if err := conn.WriteMessage(websocket.PongMessage, []byte(pingData)); err != nil {
// if err == websocket.ErrCloseSent {
// return nil
// }
// if netErr, ok := err.(interface{ Timeout() bool }); ok && netErr.Timeout() {
// return nil
// }
// return err
// } // }
if err := conn.WriteMessage(websocket.PongMessage, []byte(pingData)); err != nil {
if err == websocket.ErrCloseSent {
return nil
}
if netErr, ok := err.(interface{ Timeout() bool }); ok && netErr.Timeout() {
return nil
}
return err
}
return nil return nil
}) })