From c1fe26017bf4ec92516d0a1e86a3b578fdf2c5a4 Mon Sep 17 00:00:00 2001 From: "pre-commit-ci[bot]" <66853113+pre-commit-ci[bot]@users.noreply.github.com> Date: Tue, 30 Apr 2024 18:13:46 +0000 Subject: [PATCH] [pre-commit.ci] auto fixes from pre-commit.com hooks for more information, see https://pre-commit.ci --- pycrdt_websocket/yroom.py | 17 ++++++++--------- 1 file changed, 8 insertions(+), 9 deletions(-) diff --git a/pycrdt_websocket/yroom.py b/pycrdt_websocket/yroom.py index 462800f..f980143 100644 --- a/pycrdt_websocket/yroom.py +++ b/pycrdt_websocket/yroom.py @@ -14,7 +14,6 @@ create_task_group, ) from anyio.abc import TaskGroup, TaskStatus -from anyio.streams.memory import MemoryObjectReceiveStream, MemoryObjectSendStream from pycrdt import Doc, Subscription from .awareness import Awareness @@ -59,20 +58,20 @@ def __init__( returns True if the exception was handled. log: An optional logger. """ - self.ydoc : Doc = Doc() + self.ydoc: Doc = Doc() self.awareness = Awareness(self.ydoc) - self.ready_event : Event = Event() + self.ready_event: Event = Event() self.ready = ready - self.ystore : BaseYStore | None = ystore + self.ystore: BaseYStore | None = ystore self.log = log or getLogger(__name__) - self.clients : list = [] - self._on_message : Callable[[bytes], Awaitable[bool] | bool] | None = None + self.clients: list = [] + self._on_message: Callable[[bytes], Awaitable[bool] | bool] | None = None self.exception_handler = exception_handler - self._stopped : Event = Event() + self._stopped: Event = Event() self._update_send_stream, self._update_receive_stream = create_memory_object_stream( - max_buffer_size=0 + max_buffer_size=0 ) - self._task_group : TaskGroup | None = None + self._task_group: TaskGroup | None = None self._started: Event | None = None self.__start_lock: Lock | None = None self._subscription: Subscription | None = None