(self)
| 163 | self.is_closed = False |
| 164 | |
| 165 | def close(self): |
| 166 | if self.is_closed: |
| 167 | return |
| 168 | |
| 169 | self.is_closed = True |
| 170 | |
| 171 | if self.proxy_to_backend_task is not None: |
| 172 | self.proxy_to_backend_task.cancel() |
| 173 | self.proxy_to_backend_task = None |
| 174 | |
| 175 | if self.proxy_from_backend_task is not None: |
| 176 | self.proxy_from_backend_task.cancel() |
| 177 | self.proxy_from_backend_task = None |
| 178 | |
| 179 | self.proxy._close_connection(self) |
| 180 | |
| 181 | async def handle(self): |
| 182 | self.proxy_to_backend_task = asyncio.ensure_future( |
no test coverage detected