(self)
| 863 | logger.debug("%r resumes reading", self) |
| 864 | |
| 865 | def close(self): |
| 866 | if self._closing: |
| 867 | return |
| 868 | self._closing = True |
| 869 | self._loop._remove_reader(self._sock_fd) |
| 870 | if not self._buffer: |
| 871 | self._conn_lost += 1 |
| 872 | self._loop._remove_writer(self._sock_fd) |
| 873 | self._call_soon(self._call_connection_lost, None) |
| 874 | |
| 875 | def __del__(self, _warn=warnings.warn): |
| 876 | if self._sock is not None: |
no test coverage detected