(msg)
| 69 | msg_received = False |
| 70 | |
| 71 | def handle_message(msg): |
| 72 | nonlocal error_received, msg_received |
| 73 | if msg.get("e") == "error": |
| 74 | error_received = True |
| 75 | logger.debug("Received WebSocket error: %s", msg.get('m', 'Unknown error')) |
| 76 | return |
| 77 | msg_received = True |
| 78 | logger.debug("Received valid message") |
| 79 | |
| 80 | try: |
| 81 | logger.debug("Starting ThreadedWebsocketManager") |
nothing calls this directly
no outgoing calls
no test coverage detected
searching dependent graphs…