class Binance::WebSocketBase

def onmessage(cbs)
  @ws_connection.onmessage do |msg, type|
    cbs[:onmessage].call(msg, type) if cbs.key?(:onmessage) && cbs[:onmessage].respond_to?(:call)
  end
end