fixup! Huobi: Add V2 websocket support

gbjk · Feb 17, 2025 · 65e81e4 · 65e81e4
1 parent 4d1b1de
commit 65e81e4
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/exchanges/huobi/huobi_websocket.go b/exchanges/huobi/huobi_websocket.go
@@ -178,9 +178,7 @@ func (h *HUOBI) wsHandleV2ping(respRaw []byte) error {
 
 func (h *HUOBI) wsHandleV2subResp(action string, respRaw []byte) error {
 	if ch, err := jsonparser.GetString(respRaw, "ch"); err == nil {
-		if !h.Websocket.Match.IncomingWithData(action+":"+ch, respRaw) {
-			return fmt.Errorf("%w: %s:%s", stream.ErrNoMessageListener, action, ch)
-		}
+		return h.Websocket.Match.RequireMatchWithData(action+":"+ch, respRaw)
 	}
 	return nil
 }