diff --git a/ws_client/client.go b/ws_client/client.go index 24c515a..e34b37c 100644 --- a/ws_client/client.go +++ b/ws_client/client.go @@ -31,6 +31,12 @@ func NewWebSocketClient(scheme, host, path string) (*WebSocketClient, error) { conn: conn, done: make(chan struct{}), } + defer func() { + if r := recover(); r != nil { + log.Print("Recovered in NewWebSocketClient:", r) + go client.receiveMessages() + } + }() go client.receiveMessages()