@@ -79,9 +79,7 @@ def __init__(self, real_loop: asyncio.AbstractEventLoop) -> None:
7979 self ._real_loop = real_loop
8080
8181 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
8583 self ._closing_selector = False
8684 self ._thread : threading .Thread | None = None
8785 self ._thread_manager_handle = self ._thread_manager ()
@@ -94,9 +92,7 @@ async def thread_manager_anext() -> None:
9492 # When the loop starts, start the thread. Not too soon because we can't
9593 # clean up if we get to this point but the event loop is closed without
9694 # 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 ()))
10096
10197 self ._readers : dict [_FileDescriptorLike , Callable ] = {}
10298 self ._writers : dict [_FileDescriptorLike , Callable ] = {}
@@ -237,9 +233,7 @@ def _run_select(self) -> None:
237233 # Swallow it too for consistency.
238234 pass
239235
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 :
243237 for r in rs :
244238 self ._handle_event (r , self ._readers )
245239 for w in ws :
@@ -358,8 +352,7 @@ def _set_selector_windows() -> None:
358352 if not (
359353 sys .platform == "win32"
360354 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"
363356 ):
364357 return
365358
0 commit comments