Skip to content

Commit

Permalink
[pre-commit.ci] auto fixes from pre-commit.com hooks
Browse files Browse the repository at this point in the history
for more information, see https://pre-commit.ci
  • Loading branch information
pre-commit-ci[bot] committed Apr 30, 2024
1 parent 8f70b9f commit c1fe260
Showing 1 changed file with 8 additions and 9 deletions.
17 changes: 8 additions & 9 deletions pycrdt_websocket/yroom.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -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
Expand Down

0 comments on commit c1fe260

Please sign in to comment.