(self, buf, write=_write)
| 379 | _read = os.read |
| 380 | |
| 381 | def _send(self, buf, write=_write): |
| 382 | remaining = len(buf) |
| 383 | while True: |
| 384 | n = write(self._handle, buf) |
| 385 | remaining -= n |
| 386 | if remaining == 0: |
| 387 | break |
| 388 | buf = buf[n:] |
| 389 | |
| 390 | def _recv(self, size, read=_read): |
| 391 | buf = io.BytesIO() |
no test coverage detected