(self, connection)
| 141 | self.restore_connectivity() |
| 142 | |
| 143 | def _close_connection(self, connection): |
| 144 | conn_task = self.connections.pop(connection, None) |
| 145 | if conn_task is not None: |
| 146 | conn_task.cancel() |
| 147 | |
| 148 | def close_all_connections(self): |
| 149 | for conn in list(self.connections): |