🐛 fix reconnect

This commit is contained in:
Akiba
2022-05-24 16:07:29 +08:00
parent 36b9b59e9e
commit b07d9ab2c4

View File

@@ -74,13 +74,13 @@ func (c *Client) Start() error {
if err != nil {
log.Info("reconnecting...")
c.Stop()
retry:
err = c.ConnectAndStart()
if err != nil {
time.Sleep(1 * time.Second)
goto retry
for {
err = c.ConnectAndStart()
if err == nil {
return
}
time.Sleep(2 * time.Second)
}
break
}
if msgType != websocket.BinaryMessage {
log.Error("packet not binary", data)