(self, message: dict)
| 409 | self._handle_request(message) |
| 410 | |
| 411 | def _handle_request(self, message: dict): |
| 412 | method = message.get("method", "") |
| 413 | handler = self.request_handlers.get(method) |
| 414 | if not handler: |
| 415 | if self._loop: |
| 416 | asyncio.run_coroutine_threadsafe( |
| 417 | self._send_error_response( |
| 418 | message["id"], -32601, f"Method not found: {message['method']}", None |
| 419 | ), |
| 420 | self._loop, |
| 421 | ) |
| 422 | return |
| 423 | if not self._loop: |
| 424 | return |
| 425 | asyncio.run_coroutine_threadsafe( |
| 426 | self._dispatch_request(message, handler), |
| 427 | self._loop, |
| 428 | ) |
| 429 | |
| 430 | async def _dispatch_request(self, message: dict, handler: RequestHandler): |
| 431 | try: |
no test coverage detected