diff --git a/v1/client/client.go b/v1/client/client.go index b6c0429..2f59688 100644 --- a/v1/client/client.go +++ b/v1/client/client.go @@ -294,6 +294,11 @@ func (wsClient *SafeWebsocketClient) reconnectHandler() { default: // prevent blocking if chan is full } } + if len(wsClient.reconnectChans) > 1 { + wsClient.reconnectChans = wsClient.reconnectChans[1:] + } else { + wsClient.reconnectChans = nil + } } case <-wsClient.ctx.Done(): log.Println("reconnect handler stopped due to client shutdown")