(self, transport: asyncio.BaseTransport)
| 62 | self.messages.put(line.decode().rstrip("\r\n")) |
| 63 | |
| 64 | def connection_made(self, transport: asyncio.BaseTransport) -> None: |
| 65 | self.parser = self.parse() |
| 66 | next(self.parser) |
| 67 | |
| 68 | def data_received(self, data: bytes) -> None: |
| 69 | self.reader.feed_data(data) |