(self, client: Client, message)
| 223 | return await self.watch_public(topics, messageHashes, params, True) |
| 224 | |
| 225 | def handle_ticker(self, client: Client, message): |
| 226 | # |
| 227 | # { |
| 228 | # data: { |
| 229 | # E: '1754176123312507', |
| 230 | # V: '19419526.742584', |
| 231 | # c: '3398.57', |
| 232 | # e: 'ticker', |
| 233 | # h: '3536.65', |
| 234 | # l: '3371.8', |
| 235 | # n: 17152, |
| 236 | # o: '3475.45', |
| 237 | # s: 'ETH_USDC', |
| 238 | # v: '5573.5827' |
| 239 | # }, |
| 240 | # stream: 'bookTicker.ETH_USDC' |
| 241 | # } |
| 242 | # |
| 243 | ticker = self.safe_dict(message, 'data', {}) |
| 244 | marketId = self.safe_string(ticker, 's') |
| 245 | market = self.safe_market(marketId) |
| 246 | symbol = self.safe_symbol(marketId, market) |
| 247 | parsedTicker = self.parse_ws_ticker(ticker, market) |
| 248 | messageHash = 'ticker' + ':' + symbol |
| 249 | self.tickers[symbol] = parsedTicker |
| 250 | client.resolve(parsedTicker, messageHash) |
| 251 | |
| 252 | def parse_ws_ticker(self, ticker: dict, market: Market = None) -> Ticker: |
| 253 | # |
no test coverage detected