| 284 | |
| 285 | print("Example 16") |
| 286 | class AsyncConnection: |
| 287 | def __init__(self, reader, writer): # Changed |
| 288 | self.reader = reader # Changed |
| 289 | self.writer = writer # Changed |
| 290 | |
| 291 | async def send(self, command): |
| 292 | line = command + "\n" |
| 293 | data = line.encode() |
| 294 | self.writer.write(data) # Changed |
| 295 | await self.writer.drain() # Changed |
| 296 | |
| 297 | async def receive(self): |
| 298 | line = await self.reader.readline() # Changed |
| 299 | if not line: |
| 300 | raise EOFError("Connection closed") |
| 301 | return line[:-1].decode() |
| 302 | |
| 303 | |
| 304 | print("Example 17") |