diff --git a/pycrdt_websocket/yroom.py b/pycrdt_websocket/yroom.py index 0de11af..a2a8b3d 100644 --- a/pycrdt_websocket/yroom.py +++ b/pycrdt_websocket/yroom.py @@ -194,8 +194,8 @@ 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) + 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)