(self)
| 236 | self._scrape_next() |
| 237 | |
| 238 | def _scrape_next(self) -> None: |
| 239 | assert self.slot is not None # typing |
| 240 | while self.slot.queue: |
| 241 | result, request, queue_dfd = self.slot.next_response_request_deferred() |
| 242 | _schedule_coro(self._wait_for_processing(result, request, queue_dfd)) |
| 243 | |
| 244 | async def _scrape(self, result: Response | Failure, request: Request) -> None: |
| 245 | """Handle the downloaded response or failure through the spider callback/errback.""" |
no test coverage detected