| 1452 | |
| 1453 | class CustomRequest(ClientRequest): |
| 1454 | async def send(self, conn): |
| 1455 | resp = self.response_class( |
| 1456 | self.method, |
| 1457 | self.url, |
| 1458 | writer=self._writer, |
| 1459 | continue100=self._continue, |
| 1460 | timer=self._timer, |
| 1461 | request_info=self.request_info, |
| 1462 | traces=self._traces, |
| 1463 | loop=self.loop, |
| 1464 | session=self._session, |
| 1465 | stream_writer=mock.create_autospec( |
| 1466 | AbstractStreamWriter, spec_set=True, instance=True |
| 1467 | ), |
| 1468 | ) |
| 1469 | self.response = resp |
| 1470 | nonlocal called |
| 1471 | called = True |
| 1472 | return resp |
| 1473 | |
| 1474 | async def create_connection(req, traces, timeout): |
| 1475 | assert isinstance(req, CustomRequest) |