Wait until transport is writable.
(self)
| 98 | self._is_writable_event.set() |
| 99 | |
| 100 | async def drain(self): |
| 101 | """Wait until transport is writable.""" |
| 102 | await self._is_writable_event.wait() |
| 103 | |
| 104 | def pause_reading(self): |
| 105 | if not self.read_paused: |
no test coverage detected