(self)
| 19 | await self._is_writable_event.wait() # pragma: full coverage |
| 20 | |
| 21 | def pause_reading(self) -> None: |
| 22 | if not self.read_paused: |
| 23 | self.read_paused = True |
| 24 | self._transport.pause_reading() |
| 25 | |
| 26 | def resume_reading(self) -> None: |
| 27 | if self.read_paused: |
no outgoing calls
no test coverage detected