(
self, response: Response, result: AsyncIterator[_T]
)
| 172 | return MutableAsyncChain(result, recovered) |
| 173 | |
| 174 | async def _process_callback_output( |
| 175 | self, response: Response, result: AsyncIterator[_T] |
| 176 | ) -> MutableAsyncChain[_T]: |
| 177 | recovered: MutableAsyncChain[_T] = MutableAsyncChain() |
| 178 | result = self._evaluate_iterable(response, result, 0, recovered) |
| 179 | result = self._process_spider_output(response, result) |
| 180 | return MutableAsyncChain(result, recovered) |
| 181 | |
| 182 | def scrape_response( |
| 183 | self, |
no test coverage detected