move queue puts to main loop

Author: bollwyvl

py_src/jupyter_lsp/session.py

@@ -8,6 +8,7 @@
 from copy import copy
 from datetime import datetime, timezone
 
+from tornado.ioloop import IOLoop
 from tornado.queues import Queue
 from tornado.websocket import WebSocketHandler
 from traitlets import Bunch, Instance, Set, Unicode, UseEnum, observe
@@ -130,7 +131,7 @@ def write(self, message):
         """ wrapper around the write queue to keep it mostly internal
         """
         self.last_handler_message_at = self.now()
-        self.to_lsp.put_nowait(message)
+        IOLoop.current().add_callback(self.to_lsp.put_nowait, message)
 
     def now(self):
         return datetime.now(timezone.utc)

py_src/jupyter_lsp/stdio.py

@@ -15,6 +15,7 @@
 
 from tornado.httputil import HTTPHeaders
 from tornado.queues import Queue
+from tornado.ioloop import IOLoop
 from traitlets import Float, Instance, default
 from traitlets.config import LoggingConfigurable
 
@@ -87,7 +88,7 @@ async def read(self) -> None:
                 else:
                     self.wake()
 
-                await self.queue.put(message)
+                IOLoop.current().add_callback(self.queue.put, message)
             except Exception:  # pragma: no cover
                 self.log.exception("%s couldn't enqueue message: %s", self, message)
                 await self.sleep()