(self, unreader, buf, stop=False)
| 459 | super().__init__(cfg, unreader, peer_addr) |
| 460 | |
| 461 | def get_data(self, unreader, buf, stop=False): |
| 462 | data = unreader.read() |
| 463 | if not data: |
| 464 | if stop: |
| 465 | raise StopIteration() |
| 466 | raise NoMoreData(buf.getvalue()) |
| 467 | buf.write(data) |
| 468 | |
| 469 | def parse(self, unreader): |
| 470 | buf = bytearray() |
no test coverage detected