(
self, stop_after_crawl: bool, install_signal_handlers: bool
)
| 1037 | loop.call_soon_threadsafe(task.cancel) |
| 1038 | |
| 1039 | def _start_twisted( |
| 1040 | self, stop_after_crawl: bool, install_signal_handlers: bool |
| 1041 | ) -> None: |
| 1042 | from twisted.internet import reactor |
| 1043 | |
| 1044 | if stop_after_crawl: |
| 1045 | loop = asyncio.get_event_loop() |
| 1046 | join_task = loop.create_task(self.join()) |
| 1047 | join_task.add_done_callback(self._stop_reactor) |
| 1048 | |
| 1049 | self._setup_reactor(install_signal_handlers) |
| 1050 | reactor.run(installSignalHandlers=install_signal_handlers) # blocking call |
no test coverage detected