diff --git a/v2/websocket_service.go b/v2/websocket_service.go index 5e7a4681a..7c81be2fe 100644 --- a/v2/websocket_service.go +++ b/v2/websocket_service.go @@ -144,12 +144,12 @@ func (b *bfxWebsocket) receiver() { select { case <-b.Done(): return - default: } _, msg, err := b.ws.ReadMessage() if err != nil { b.close(err) + return }