(self, exc)
| 149 | waiter.set_result(None) |
| 150 | |
| 151 | def connection_lost(self, exc): |
| 152 | self._connection_lost = True |
| 153 | # Wake up the writer(s) if currently paused. |
| 154 | if not self._paused: |
| 155 | return |
| 156 | |
| 157 | for waiter in self._drain_waiters: |
| 158 | if not waiter.done(): |
| 159 | if exc is None: |
| 160 | waiter.set_result(None) |
| 161 | else: |
| 162 | waiter.set_exception(exc) |
| 163 | |
| 164 | async def _drain_helper(self): |
| 165 | if self._connection_lost: |
no test coverage detected