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