(self, setup: Request)
| 142 | |
| 143 | @override |
| 144 | async def request(self, setup: Request) -> Response: |
| 145 | if self._params: |
| 146 | url = setup.url.with_query({**self._params, **setup.url.query}) |
| 147 | else: |
| 148 | url = setup.url |
| 149 | |
| 150 | data = setup.data |
| 151 | if setup.files: |
| 152 | data = aiohttp.FormData(data or {}, quote_fields=False) |
| 153 | for name, file in setup.files: |
| 154 | data.add_field(name, file[1], content_type=file[2], filename=file[0]) |
| 155 | |
| 156 | cookies = ( |
| 157 | (cookie.name, cookie.value) |
| 158 | for cookie in setup.cookies |
| 159 | if cookie.value is not None |
| 160 | ) |
| 161 | |
| 162 | async with await self.client.request( |
| 163 | setup.method, |
| 164 | url, |
| 165 | data=setup.content or data, |
| 166 | json=setup.json, |
| 167 | cookies=cookies, |
| 168 | headers=setup.headers, |
| 169 | proxy=setup.proxy or self._proxy, |
| 170 | timeout=self._get_timeout(setup.timeout), |
| 171 | ) as response: |
| 172 | return Response( |
| 173 | response.status, |
| 174 | headers=response.headers.copy(), |
| 175 | content=await response.read(), |
| 176 | request=setup, |
| 177 | ) |
| 178 | |
| 179 | @override |
| 180 | async def stream_request( |
nothing calls this directly
no test coverage detected