(self, client: Client, message)
| 335 | return await self.watch_public(topics, messageHashes, params, True) |
| 336 | |
| 337 | def handle_bid_ask(self, client: Client, message): |
| 338 | # |
| 339 | # { |
| 340 | # data: { |
| 341 | # A: '0.4087', |
| 342 | # B: '0.0020', |
| 343 | # E: '1754517402450016', |
| 344 | # T: '1754517402449064', |
| 345 | # a: '3667.50', |
| 346 | # b: '3667.49', |
| 347 | # e: 'bookTicker', |
| 348 | # s: 'ETH_USDC', |
| 349 | # u: 1328288557 |
| 350 | # }, |
| 351 | # stream: 'bookTicker.ETH_USDC' |
| 352 | # } |
| 353 | data = self.safe_dict(message, 'data', {}) |
| 354 | marketId = self.safe_string(data, 's') |
| 355 | market = self.safe_market(marketId) |
| 356 | symbol = self.safe_symbol(marketId, market) |
| 357 | parsedBidAsk = self.parse_ws_bid_ask(data, market) |
| 358 | messageHash = 'bidask' + ':' + symbol |
| 359 | self.bidsasks[symbol] = parsedBidAsk |
| 360 | client.resolve(parsedBidAsk, messageHash) |
| 361 | |
| 362 | def parse_ws_bid_ask(self, ticker, market: Market = None): |
| 363 | # |
no test coverage detected