(self)
| 268 | self._buffer += r |
| 269 | |
| 270 | def _read_line(self): |
| 271 | while True: |
| 272 | i = self._buffer.find(b"\n") |
| 273 | if i != -1: |
| 274 | i += 1 # Add the newline to the return |
| 275 | ret = self._buffer[:i] |
| 276 | self._buffer = self._buffer[i:] |
| 277 | return ret |
| 278 | else: |
| 279 | r = self.sock.recv(1024) |
| 280 | if not r: |
| 281 | return b"" |
| 282 | self._buffer += r |
| 283 | |
| 284 | def run(self): |
| 285 | try: |