(self, size, read=_read)
| 405 | buf = buf[n:] |
| 406 | |
| 407 | def _recv(self, size, read=_read): |
| 408 | buf = io.BytesIO() |
| 409 | handle = self._handle |
| 410 | remaining = size |
| 411 | while remaining > 0: |
| 412 | to_read = min(BUFSIZE, remaining) |
| 413 | chunk = read(handle, to_read) |
| 414 | n = len(chunk) |
| 415 | if n == 0: |
| 416 | if remaining == size: |
| 417 | raise EOFError |
| 418 | else: |
| 419 | raise OSError("got end of file during message") |
| 420 | buf.write(chunk) |
| 421 | remaining -= n |
| 422 | return buf |
| 423 | |
| 424 | def _send_bytes(self, buf): |
| 425 | n = len(buf) |
no test coverage detected