(self)
| 771 | length = 0 |
| 772 | |
| 773 | def _write_eof_payload(self): |
| 774 | while True: |
| 775 | try: |
| 776 | chunk = yield |
| 777 | except aiohttp.EofStream: |
| 778 | break |
| 779 | |
| 780 | self.transport.write(chunk) |
| 781 | self.output_length += len(chunk) |
| 782 | |
| 783 | @wrap_payload_filter |
| 784 | def add_chunking_filter(self, chunk_size=16*1024, *, |