(self, response)
| 331 | ) from ie |
| 332 | |
| 333 | def _get_raw_response_socket(self, response): |
| 334 | self._raise_for_status(response) |
| 335 | if self.base_url == "http+docker://localnpipe": |
| 336 | sock = response.raw._fp.fp.raw.sock |
| 337 | elif self.base_url.startswith('http+docker://ssh'): |
| 338 | sock = response.raw._fp.fp.channel |
| 339 | else: |
| 340 | sock = response.raw._fp.fp.raw |
| 341 | if self.base_url.startswith("https://"): |
| 342 | sock = sock._sock |
| 343 | try: |
| 344 | # Keep a reference to the response to stop it being garbage |
| 345 | # collected. If the response is garbage collected, it will |
| 346 | # close TLS sockets. |
| 347 | sock._response = response |
| 348 | except AttributeError: |
| 349 | # UNIX sockets can't have attributes set on them, but that's |
| 350 | # fine because we won't be doing TLS over them |
| 351 | pass |
| 352 | |
| 353 | return sock |
| 354 | |
| 355 | def _stream_helper(self, response, decode=False): |
| 356 | """Generator for data coming from a chunked-encoded HTTP response.""" |
no test coverage detected