(self, request: Request, spider: Spider)
| 96 | ) |
| 97 | |
| 98 | def download_request(self, request: Request, spider: Spider) -> Deferred[Response]: |
| 99 | from twisted.internet import reactor |
| 100 | |
| 101 | timeout = request.meta.get("download_timeout") or self._connect_timeout |
| 102 | agent = self._get_agent(request, timeout) |
| 103 | |
| 104 | start_time = monotonic() |
| 105 | d = agent.request(request, spider) |
| 106 | d.addCallback(self._cb_latency, request, start_time) |
| 107 | |
| 108 | timeout_cl = reactor.callLater(timeout, d.cancel) |
| 109 | d.addBoth(self._cb_timeout, request, timeout, timeout_cl) |
| 110 | return d |
| 111 | |
| 112 | @staticmethod |
| 113 | def _cb_latency( |
no test coverage detected