(self)
| 248 | self._write_ready_fut = self._transport._loop.create_future() |
| 249 | |
| 250 | def resume_writing(self): |
| 251 | if self._write_ready_fut is None: |
| 252 | return |
| 253 | self._write_ready_fut.set_result(False) |
| 254 | self._write_ready_fut = None |
| 255 | |
| 256 | def data_received(self, data): |
| 257 | raise RuntimeError("Invalid state: reading should be paused") |