(self)
| 215 | logger.debug("%r pauses reading", self) |
| 216 | |
| 217 | def resume_reading(self): |
| 218 | if self._closing or not self._paused: |
| 219 | return |
| 220 | |
| 221 | self._paused = False |
| 222 | if self._read_fut is None: |
| 223 | self._loop.call_soon(self._loop_reading, None) |
| 224 | |
| 225 | length = self._pending_data_length |
| 226 | self._pending_data_length = -1 |
| 227 | if length > -1: |
| 228 | # Call the protocol method after calling _loop_reading(), |
| 229 | # since the protocol can decide to pause reading again. |
| 230 | self._loop.call_soon(self._data_received, self._data[:length], length) |
| 231 | |
| 232 | if self._loop.get_debug(): |
| 233 | logger.debug("%r resumes reading", self) |
| 234 | |
| 235 | def _eof_received(self): |
| 236 | if self._loop.get_debug(): |
no test coverage detected