(self, target)
| 98 | self._step_task(main_task) |
| 99 | |
| 100 | async def _start_main_task(self, target): |
| 101 | await target() |
| 102 | if self.need_keep_alive(): |
| 103 | from ..session import hold |
| 104 | await hold() |
| 105 | |
| 106 | def _step_task(self, task, result=None): |
| 107 | asyncio.get_event_loop().call_soon_threadsafe(partial(task.step, result)) |
no test coverage detected