(self, stream: IOStream)
| 497 | self._timeout = None |
| 498 | |
| 499 | def _create_connection(self, stream: IOStream) -> HTTP1Connection: |
| 500 | stream.set_nodelay(True) |
| 501 | connection = HTTP1Connection( |
| 502 | stream, |
| 503 | True, |
| 504 | HTTP1ConnectionParameters( |
| 505 | no_keep_alive=True, |
| 506 | max_header_size=self.max_header_size, |
| 507 | max_body_size=self.max_body_size, |
| 508 | decompress=bool(self.request.decompress_response), |
| 509 | ), |
| 510 | self._sockaddr, |
| 511 | ) |
| 512 | return connection |
| 513 | |
| 514 | async def _write_body(self, start_read: bool) -> None: |
| 515 | if self.request.body is not None: |
no test coverage detected