From 4e610460f425ef12b8e674df0304fced789aef33 Mon Sep 17 00:00:00 2001
From: David Brochart <david.brochart@gmail.com>
Date: Mon, 29 Apr 2024 15:47:31 +0200
Subject: [PATCH] Fix room async context manager

---
 pycrdt_websocket/yroom.py | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/pycrdt_websocket/yroom.py b/pycrdt_websocket/yroom.py
index ea88227..a2a8b3d 100644
--- 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)