(self)
| 864 | self._app_reading_paused = True |
| 865 | |
| 866 | def _resume_reading(self): |
| 867 | if self._app_reading_paused: |
| 868 | self._app_reading_paused = False |
| 869 | |
| 870 | def resume(): |
| 871 | if self._state == SSLProtocolState.WRAPPED: |
| 872 | self._do_read() |
| 873 | elif self._state == SSLProtocolState.FLUSHING: |
| 874 | self._do_flush() |
| 875 | elif self._state == SSLProtocolState.SHUTDOWN: |
| 876 | self._do_shutdown() |
| 877 | self._loop.call_soon(resume) |
| 878 | |
| 879 | # Flow control for reads from SSL socket |
| 880 |
no test coverage detected