(self)
| 118 | future.result() |
| 119 | |
| 120 | def _get_reactorless_loop(self) -> asyncio.AbstractEventLoop: |
| 121 | assert self.crawler_process |
| 122 | assert isinstance(self.crawler_process, AsyncCrawlerProcess) |
| 123 | loop = self.crawler_process._reactorless_loop |
| 124 | assert loop |
| 125 | return loop |
| 126 | |
| 127 | def _start_crawler_thread(self) -> None: |
| 128 | """Run self.crawler_process.start() in a separate thread.""" |
no outgoing calls
no test coverage detected