use async jsonrpc api

Author: davschul

pylsp/python_lsp.py

@@ -6,6 +6,7 @@
 import os
 import socketserver
 import threading
+import asyncio
 
 from pylsp_jsonrpc.dispatchers import MethodDispatcher
 from pylsp_jsonrpc.endpoint import Endpoint
@@ -115,7 +116,14 @@ def __init__(self, rx, tx, check_parent_process=False):
 
     def start(self):
         """Entry point for the server."""
-        self._jsonrpc_stream_reader.listen(self._endpoint.consume)
+        asyncio.run(self.start_async())
+
+    async def start_async(self):
+        self._endpoint.init_async()
+        await asyncio.gather(
+            self._jsonrpc_stream_reader.listen_async(self._endpoint.consume_async),
+            self._endpoint.consume_task()
+        )
 
     def __getitem__(self, item):
         """Override getitem to fallback through multiple dispatchers."""