File tree Expand file tree Collapse file tree 2 files changed +11
-10
lines changed Expand file tree Collapse file tree 2 files changed +11
-10
lines changed Original file line number Diff line number Diff line change @@ -700,13 +700,13 @@ async def run(self) -> None:
700700 future = self .future
701701 if future is None :
702702 raise Exception ("No pending future" )
703- if not self .future .done ():
703+ if not self .future .done (): # type: ignore
704704 _step = asyncio .Event ()
705705
706- def step (* args ) :
706+ def step (f : "Future[_T]" ) -> None :
707707 _step .set ()
708708
709- self .io_loop .add_future (self .future , step )
709+ self .io_loop .add_future (self .future , step ) # type: ignore
710710 await _step .wait ()
711711 self .future = None
712712 try :
@@ -748,18 +748,17 @@ def step(*args):
748748 if self .future is moment :
749749 await sleep (0 )
750750
751- def handle_yield (self , yielded : _Yieldable ) -> bool :
751+ def handle_yield (self , yielded : _Yieldable ) -> None :
752752 try :
753753 self .future = convert_yielded (yielded )
754754 except BadYieldError :
755755 self .future = Future ()
756756 future_set_exc_info (self .future , sys .exc_info ())
757757
758- def finish (self , future ) :
758+ def finish (self , future : "Future[_T]" ) -> None :
759759 if future .cancelled ():
760760 self .task .cancel ()
761- self .future .cancel ()
762- self .task = None
761+ self .future .cancel () # type: ignore
763762
764763
765764# Convert Awaitables into Futures.
Original file line number Diff line number Diff line change @@ -506,9 +506,11 @@ def run() -> None:
506506 future_cell [0 ] = fut
507507 fut .set_result (result )
508508 assert future_cell [0 ] is not None
509- self .add_future (
510- future_cell [0 ], lambda f : f .add_done_callback (lambda _ : self .stop ())
511- )
509+
510+ def _stop (f : "Future[_T]" ) -> None :
511+ f .add_done_callback (lambda _ : self .stop ())
512+
513+ self .add_future (future_cell [0 ], _stop )
512514
513515 self .add_callback (run )
514516 if timeout is not None :
You can’t perform that action at this time.
0 commit comments