Threaded dispatcher loop

requirements/pkg-deps.txt

@@ -1,2 +1,3 @@
 channels<4.0.0 # Django websocket features
 idom >=0.33.0, <0.34.0
+janus < 1.0.0

src/django_idom/websocket_consumer.py

@@ -2,9 +2,11 @@
 import asyncio
 import json
 import logging
+from threading import Thread
 from typing import Any
 from urllib.parse import parse_qsl
 
+import janus
 from channels.generic.websocket import AsyncJsonWebsocketConsumer
 from idom.core.dispatcher import dispatch_single_view
 from idom.core.layout import Layout, LayoutEvent
@@ -23,14 +25,15 @@ def __init__(self, *args: Any, **kwargs: Any) -> None:
 
     async def connect(self) -> None:
         await super().connect()
-        self._idom_dispatcher_future = asyncio.ensure_future(self._run_dispatch_loop())
+        self._idom_dispatcher_thread = Thread(
+            target=asyncio.run,
+            args=(self._run_dispatch_loop(),),
+        )
+        self._idom_dispatcher_thread.daemon = True
+        self._idom_dispatcher_thread.start()
 
     async def disconnect(self, code: int) -> None:
-        if self._idom_dispatcher_future.done():
-            await self._idom_dispatcher_future
-        else:
-            self._idom_dispatcher_future.cancel()
-        await super().disconnect(code)
+        self._idom_dispatcher_thread.join(timeout=0)
 
     async def receive_json(self, content: Any, **kwargs: Any) -> None:
         await self._idom_recv_queue.put(LayoutEvent(**content))
@@ -56,12 +59,13 @@ async def _run_dispatch_loop(self):
             )
             return
 
-        self._idom_recv_queue = recv_queue = asyncio.Queue()
+        # Thread-safe queue
+        self._idom_recv_queue = janus.Queue().async_q
         try:
             await dispatch_single_view(
                 Layout(component_instance),
                 self.send_json,
-                recv_queue.get,
+                self._idom_recv_queue.get,
             )
         except Exception:
             await self.close()