(self)
| 693 | return len(self._buffer) |
| 694 | |
| 695 | def _read_ready(self): |
| 696 | # Pipe was closed by peer. |
| 697 | if self._loop.get_debug(): |
| 698 | logger.info("%r was closed by peer", self) |
| 699 | if self._buffer: |
| 700 | self._close(BrokenPipeError()) |
| 701 | else: |
| 702 | self._close() |
| 703 | |
| 704 | def write(self, data): |
| 705 | assert isinstance(data, (bytes, bytearray, memoryview)), repr(data) |