(self)
| 1035 | exc, 'Fatal error: protocol.data_received() call failed.') |
| 1036 | |
| 1037 | def _read_ready__on_eof(self): |
| 1038 | if self._loop.get_debug(): |
| 1039 | logger.debug("%r received EOF", self) |
| 1040 | |
| 1041 | try: |
| 1042 | keep_open = self._protocol.eof_received() |
| 1043 | except (SystemExit, KeyboardInterrupt): |
| 1044 | raise |
| 1045 | except BaseException as exc: |
| 1046 | self._fatal_error( |
| 1047 | exc, 'Fatal error: protocol.eof_received() call failed.') |
| 1048 | return |
| 1049 | |
| 1050 | if keep_open: |
| 1051 | # We're keeping the connection open so the |
| 1052 | # protocol can write more, but we still can't |
| 1053 | # receive more, so remove the reader callback. |
| 1054 | self._loop._remove_reader(self._sock_fd) |
| 1055 | else: |
| 1056 | self.close() |
| 1057 | |
| 1058 | def write(self, data): |
| 1059 | if not isinstance(data, (bytes, bytearray, memoryview)): |
no test coverage detected