(self, start_read: bool)
| 514 | return connection |
| 515 | |
| 516 | async def _write_body(self, start_read: bool) -> None: |
| 517 | if self.request.body is not None: |
| 518 | self.connection.write(self.request.body) |
| 519 | elif self.request.body_producer is not None: |
| 520 | fut = self.request.body_producer(self.connection.write) |
| 521 | if fut is not None: |
| 522 | await fut |
| 523 | self.connection.finish() |
| 524 | if start_read: |
| 525 | try: |
| 526 | await self.connection.read_response(self) |
| 527 | except StreamClosedError: |
| 528 | if not self._handle_exception(*sys.exc_info()): |
| 529 | raise |
| 530 | |
| 531 | def _release(self) -> None: |
| 532 | if self.release_callback is not None: |
no test coverage detected