| 72 | return self.buffer.seen_end() |
| 73 | |
| 74 | async def run(self): |
| 75 | try: |
| 76 | wire = await self.receive() |
| 77 | is_get = False |
| 78 | path: Optional[bytes] |
| 79 | for wire in self.connection.listener.server.handle_wire( |
| 80 | wire, |
| 81 | self.connection.peer, |
| 82 | self.connection.listener.socket.getsockname(), |
| 83 | self.connection.listener.connection_type, |
| 84 | ): |
| 85 | break |
| 86 | await self.send(wire, True) |
| 87 | except Exception: |
| 88 | if not self.seen_end(): |
| 89 | self.connection.reset(self.stream_id) |
| 90 | finally: |
| 91 | self.connection.stream_done(self) |
| 92 | |
| 93 | |
| 94 | class Connection: |