(self, method, url, *, cookies = None, headers = None, params = None, data = None, json = None)
| 193 | raise NotImplementedError() |
| 194 | |
| 195 | async def async_request(self, method, url, *, cookies = None, headers = None, params = None, data = None, json = None): |
| 196 | proxy = None |
| 197 | if url.startswith("http"): |
| 198 | proxy = proxies.get("http") |
| 199 | if url.startswith("https"): |
| 200 | proxy = proxies.get("https") |
| 201 | async with self.client_session.request( |
| 202 | method.name, |
| 203 | url, |
| 204 | cookies = cookies, |
| 205 | headers = headers, |
| 206 | params = params, |
| 207 | data = data, |
| 208 | json = json, |
| 209 | proxy = proxy |
| 210 | ) as resp: |
| 211 | assert isinstance(resp, aiohttp.ClientResponse) |
| 212 | content = await resp.read() |
| 213 | try: |
| 214 | text = content.decode(resp.get_encoding()) |
| 215 | except Exception: |
| 216 | text = "" |
| 217 | response = HTTPResponse( |
| 218 | request_method=method, |
| 219 | status_code=resp.status, |
| 220 | content=content, |
| 221 | text=text, |
| 222 | headers=resp.headers |
| 223 | ) |
| 224 | if self.error_handling: |
| 225 | self.check_response(response) |
| 226 | return response |
| 227 | |
| 228 | class Requests(HTTPSession): |
| 229 | """ |
nothing calls this directly
no test coverage detected