diff --git a/websocket_transport.go b/websocket_transport.go index 13345a0..e8031b2 100644 --- a/websocket_transport.go +++ b/websocket_transport.go @@ -23,7 +23,7 @@ func (t *WebsocketTransport) Connect() error { defer cancel() wsConn, _, err := websocket.Dial(ctx, t.Config.Address, nil) - if err != nil { + if err == nil { t.wsConn = wsConn t.netConn = websocket.NetConn(t.ctx, t.wsConn, websocket.MessageText) }