Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 2ab2e07b9b |
@@ -324,19 +324,19 @@ func (wsClient *SafeWebsocketClient) connect() error {
|
||||
}()
|
||||
|
||||
conn.SetPingHandler(func(pingData string) error {
|
||||
wsClient.writeChan <- Message{
|
||||
MessageType: MessageTypePong,
|
||||
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
|
||||
// wsClient.writeChan <- Message{
|
||||
// MessageType: MessageTypePong,
|
||||
// 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
|
||||
}
|
||||
return nil
|
||||
})
|
||||
|
||||
|
||||
Reference in New Issue
Block a user