Fix room async context manager

jupyter-server · Apr 29, 2024 · 4e61046 · 4e61046
1 parent 22c4dd5
commit 4e61046
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pycrdt_websocket/yroom.py b/pycrdt_websocket/yroom.py
@@ -194,6 +194,9 @@ async def start(
         if from_context_manager:
             task_status.started()
             self.started.set()
+            self._update_send_stream, self._update_receive_stream = create_memory_object_stream(
+                max_buffer_size=65536
+            )
             assert self._task_group is not None
             self._task_group.start_soon(self._stopped.wait)
             self._task_group.start_soon(self._watch_ready)