diff --git a/exchanges/poloniex/poloniex_websocket.go b/exchanges/poloniex/poloniex_websocket.go index 1142f7e6..23b79214 100644 --- a/exchanges/poloniex/poloniex_websocket.go +++ b/exchanges/poloniex/poloniex_websocket.go @@ -75,6 +75,9 @@ func (p *Poloniex) WsSubscribe() error { Command: "subscribe", Channel: fPair.String(), }) + if err != nil { + return err + } err = p.WebsocketConn.WriteMessage(websocket.TextMessage, orderbookJSON) if err != nil {