Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 2ab2e07b9b |
@@ -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
|
||||||
})
|
})
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user