(self, size, read=_read)
| 388 | buf = buf[n:] |
| 389 | |
| 390 | def _recv(self, size, read=_read): |
| 391 | buf = io.BytesIO() |
| 392 | handle = self._handle |
| 393 | remaining = size |
| 394 | while remaining > 0: |
| 395 | chunk = read(handle, remaining) |
| 396 | n = len(chunk) |
| 397 | if n == 0: |
| 398 | if remaining == size: |
| 399 | raise EOFError |
| 400 | else: |
| 401 | raise OSError("got end of file during message") |
| 402 | buf.write(chunk) |
| 403 | remaining -= n |
| 404 | return buf |
| 405 | |
| 406 | def _send_bytes(self, buf): |
| 407 | n = len(buf) |
no test coverage detected