(
self,
ctx_run: Callable,
gen: "Generator[_Yieldable, Any, _T]",
result_future: "Future[_T]",
first_yielded: _Yieldable,
)
| 730 | """ |
| 731 | |
| 732 | def __init__( |
| 733 | self, |
| 734 | ctx_run: Callable, |
| 735 | gen: "Generator[_Yieldable, Any, _T]", |
| 736 | result_future: "Future[_T]", |
| 737 | first_yielded: _Yieldable, |
| 738 | ) -> None: |
| 739 | self.ctx_run = ctx_run |
| 740 | self.gen = gen |
| 741 | self.result_future = result_future |
| 742 | self.future = _null_future # type: Union[None, Future] |
| 743 | self.running = False |
| 744 | self.finished = False |
| 745 | self.io_loop = IOLoop.current() |
| 746 | if self.handle_yield(first_yielded): |
| 747 | gen = result_future = first_yielded = None # type: ignore |
| 748 | self.ctx_run(self.run) |
| 749 | |
| 750 | def run(self) -> None: |
| 751 | """Starts or resumes the generator, running until it reaches a |
nothing calls this directly
no test coverage detected