File tree 1 file changed +4
-3
lines changed
1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change 4
4
from functools import partial
5
5
from inspect import isawaitable
6
6
from logging import Logger , getLogger
7
- from typing import Awaitable , Callable , Tuple
7
+ from typing import Awaitable , Callable
8
8
9
9
from anyio import (
10
10
TASK_STATUS_IGNORED ,
@@ -42,6 +42,7 @@ class YRoom:
42
42
_stopped : Event
43
43
__start_lock : Lock | None
44
44
_subscription : Subscription | None
45
+
45
46
def __init__ (
46
47
self ,
47
48
ready : bool = True ,
@@ -82,12 +83,12 @@ def __init__(
82
83
self .exception_handler = exception_handler
83
84
self ._stopped = Event ()
84
85
self ._update_send_stream , self ._update_receive_stream = create_memory_object_stream (
85
- max_buffer_size = 65536
86
+ max_buffer_size = 65536
86
87
)
87
88
self ._task_group = None
88
89
self ._started = None
89
90
self .__start_lock = None
90
- self ._subscription = None
91
+ self ._subscription = None
91
92
92
93
@property
93
94
def _start_lock (self ) -> Lock :
You can’t perform that action at this time.
0 commit comments