@@ -79,9 +79,7 @@ def __init__(self, real_loop: asyncio.AbstractEventLoop) -> None:
79
79
self ._real_loop = real_loop
80
80
81
81
self ._select_cond = threading .Condition ()
82
- self ._select_args : (
83
- tuple [list [_FileDescriptorLike ], list [_FileDescriptorLike ]] | None
84
- ) = None
82
+ self ._select_args : tuple [list [_FileDescriptorLike ], list [_FileDescriptorLike ]] | None = None
85
83
self ._closing_selector = False
86
84
self ._thread : threading .Thread | None = None
87
85
self ._thread_manager_handle = self ._thread_manager ()
@@ -94,9 +92,7 @@ async def thread_manager_anext() -> None:
94
92
# When the loop starts, start the thread. Not too soon because we can't
95
93
# clean up if we get to this point but the event loop is closed without
96
94
# starting.
97
- self ._real_loop .call_soon (
98
- lambda : self ._real_loop .create_task (thread_manager_anext ())
99
- )
95
+ self ._real_loop .call_soon (lambda : self ._real_loop .create_task (thread_manager_anext ()))
100
96
101
97
self ._readers : dict [_FileDescriptorLike , Callable ] = {}
102
98
self ._writers : dict [_FileDescriptorLike , Callable ] = {}
@@ -237,9 +233,7 @@ def _run_select(self) -> None:
237
233
# Swallow it too for consistency.
238
234
pass
239
235
240
- def _handle_select (
241
- self , rs : list [_FileDescriptorLike ], ws : list [_FileDescriptorLike ]
242
- ) -> None :
236
+ def _handle_select (self , rs : list [_FileDescriptorLike ], ws : list [_FileDescriptorLike ]) -> None :
243
237
for r in rs :
244
238
self ._handle_event (r , self ._readers )
245
239
for w in ws :
@@ -358,8 +352,7 @@ def _set_selector_windows() -> None:
358
352
if not (
359
353
sys .platform == "win32"
360
354
and current_async_library () == "asyncio"
361
- and asyncio .get_event_loop_policy ().__class__ .__name__
362
- == "WindowsProactorEventLoopPolicy"
355
+ and asyncio .get_event_loop_policy ().__class__ .__name__ == "WindowsProactorEventLoopPolicy"
363
356
):
364
357
return
365
358
0 commit comments