(self, client: Client, message)
| 756 | await client.send(pong) |
| 757 | |
| 758 | def handle_message(self, client: Client, message): |
| 759 | if 'channel' in message: |
| 760 | channel = self.safe_string(message, 'channel') |
| 761 | if channel.find('_depth_step') > -1: |
| 762 | self.handle_order_book(client, message) |
| 763 | elif channel.find('_trade_ticker') > -1: |
| 764 | self.handle_trades(client, message) |
| 765 | elif channel.find('_kline_') > -1: |
| 766 | self.handle_ohlcv(client, message) |
| 767 | elif channel.find('_ticker') > -1: |
| 768 | self.handle_ticker(client, message) |
| 769 | elif 'ping' in message: |
| 770 | self.handle_ping(client, message) |
| 771 | else: |
| 772 | event = self.safe_string(message, 'e') |
| 773 | handlers = { |
| 774 | 'BALANCE': self.handle_balance, |
| 775 | 'ORDER': self.handle_order, |
| 776 | } |
| 777 | handler = self.safe_value(handlers, event) |
| 778 | if handler is not None: |
| 779 | handler(client, message) |
| 780 | |
| 781 | async def authenticate(self, params={}): |
| 782 | listenKey = self.safe_value(self.options, 'listenKey') |
nothing calls this directly
no test coverage detected