(
self,
request: Request,
)
| 228 | self._pool.__exit__(exc_type, exc_value, traceback) |
| 229 | |
| 230 | def handle_request( |
| 231 | self, |
| 232 | request: Request, |
| 233 | ) -> Response: |
| 234 | assert isinstance(request.stream, SyncByteStream) |
| 235 | import httpcore |
| 236 | |
| 237 | req = httpcore.Request( |
| 238 | method=request.method, |
| 239 | url=httpcore.URL( |
| 240 | scheme=request.url.raw_scheme, |
| 241 | host=request.url.raw_host, |
| 242 | port=request.url.port, |
| 243 | target=request.url.raw_path, |
| 244 | ), |
| 245 | headers=request.headers.raw, |
| 246 | content=request.stream, |
| 247 | extensions=request.extensions, |
| 248 | ) |
| 249 | with map_httpcore_exceptions(): |
| 250 | resp = self._pool.handle_request(req) |
| 251 | |
| 252 | assert isinstance(resp.stream, typing.Iterable) |
| 253 | |
| 254 | return Response( |
| 255 | status_code=resp.status, |
| 256 | headers=resp.headers, |
| 257 | stream=ResponseStream(resp.stream), |
| 258 | extensions=resp.extensions, |
| 259 | ) |
| 260 | |
| 261 | def close(self) -> None: |
| 262 | self._pool.close() |
nothing calls this directly
no test coverage detected