(self)
| 162 | waiter.set_exception(exc) |
| 163 | |
| 164 | async def _drain_helper(self): |
| 165 | if self._connection_lost: |
| 166 | raise ConnectionResetError('Connection lost') |
| 167 | if not self._paused: |
| 168 | return |
| 169 | waiter = self._loop.create_future() |
| 170 | self._drain_waiters.append(waiter) |
| 171 | try: |
| 172 | await waiter |
| 173 | finally: |
| 174 | self._drain_waiters.remove(waiter) |
| 175 | |
| 176 | def _get_close_waiter(self, stream): |
| 177 | raise NotImplementedError |