|
30 | 30 |
|
31 | 31 |
|
32 | 32 | class YRoom:
|
33 |
| - clients: list |
34 |
| - ydoc: Doc |
35 |
| - ystore: BaseYStore | None |
36 |
| - ready_event: Event |
37 |
| - _on_message: Callable[[bytes], Awaitable[bool] | bool] | None |
38 |
| - _update_send_stream: MemoryObjectSendStream |
39 |
| - _update_receive_stream: MemoryObjectReceiveStream |
40 |
| - _task_group: TaskGroup | None = None |
41 |
| - _started: Event | None = None |
42 |
| - _stopped: Event |
43 |
| - __start_lock: Lock | None = None |
44 |
| - _subscription: Subscription | None = None |
45 |
| - |
46 | 33 | def __init__(
|
47 | 34 | self,
|
48 | 35 | ready: bool = True,
|
@@ -72,16 +59,23 @@ def __init__(
|
72 | 59 | returns True if the exception was handled.
|
73 | 60 | log: An optional logger.
|
74 | 61 | """
|
75 |
| - self.ydoc = Doc() |
| 62 | + self.ydoc : Doc = Doc() |
76 | 63 | self.awareness = Awareness(self.ydoc)
|
77 |
| - self.ready_event = Event() |
| 64 | + self.ready_event : Event = Event() |
78 | 65 | self.ready = ready
|
79 |
| - self.ystore = ystore |
| 66 | + self.ystore : BaseYStore | None = ystore |
80 | 67 | self.log = log or getLogger(__name__)
|
81 |
| - self.clients = [] |
82 |
| - self._on_message = None |
| 68 | + self.clients : list = [] |
| 69 | + self._on_message : Callable[[bytes], Awaitable[bool] | bool] | None = None |
83 | 70 | self.exception_handler = exception_handler
|
84 |
| - self._stopped = Event() |
| 71 | + self._stopped : Event = Event() |
| 72 | + self._update_send_stream, self._update_receive_stream = create_memory_object_stream( |
| 73 | + max_buffer_size=0 |
| 74 | + ) |
| 75 | + self._task_group : TaskGroup | None = None |
| 76 | + self._started: Event | None = None |
| 77 | + self.__start_lock: Lock | None = None |
| 78 | + self._subscription: Subscription | None = None |
85 | 79 |
|
86 | 80 | @property
|
87 | 81 | def _start_lock(self) -> Lock:
|
|
0 commit comments