|
14 | 14 | create_task_group,
|
15 | 15 | )
|
16 | 16 | from anyio.abc import TaskGroup, TaskStatus
|
17 |
| -from anyio.streams.memory import MemoryObjectReceiveStream, MemoryObjectSendStream |
18 | 17 | from pycrdt import Doc, Subscription
|
19 | 18 |
|
20 | 19 | from .awareness import Awareness
|
@@ -59,20 +58,20 @@ def __init__(
|
59 | 58 | returns True if the exception was handled.
|
60 | 59 | log: An optional logger.
|
61 | 60 | """
|
62 |
| - self.ydoc : Doc = Doc() |
| 61 | + self.ydoc: Doc = Doc() |
63 | 62 | self.awareness = Awareness(self.ydoc)
|
64 |
| - self.ready_event : Event = Event() |
| 63 | + self.ready_event: Event = Event() |
65 | 64 | self.ready = ready
|
66 |
| - self.ystore : BaseYStore | None = ystore |
| 65 | + self.ystore: BaseYStore | None = ystore |
67 | 66 | self.log = log or getLogger(__name__)
|
68 |
| - self.clients : list = [] |
69 |
| - self._on_message : Callable[[bytes], Awaitable[bool] | bool] | None = None |
| 67 | + self.clients: list = [] |
| 68 | + self._on_message: Callable[[bytes], Awaitable[bool] | bool] | None = None |
70 | 69 | self.exception_handler = exception_handler
|
71 |
| - self._stopped : Event = Event() |
| 70 | + self._stopped: Event = Event() |
72 | 71 | self._update_send_stream, self._update_receive_stream = create_memory_object_stream(
|
73 |
| - max_buffer_size=0 |
| 72 | + max_buffer_size=0 |
74 | 73 | )
|
75 |
| - self._task_group : TaskGroup | None = None |
| 74 | + self._task_group: TaskGroup | None = None |
76 | 75 | self._started: Event | None = None
|
77 | 76 | self.__start_lock: Lock | None = None
|
78 | 77 | self._subscription: Subscription | None = None
|
|
0 commit comments