(self, conn)
| 156 | self._notifier.send() |
| 157 | |
| 158 | def connection_created(self, conn): |
| 159 | with self._conn_set_lock: |
| 160 | new_live_conns = self._live_conns.copy() |
| 161 | new_live_conns.add(conn) |
| 162 | self._live_conns = new_live_conns |
| 163 | |
| 164 | new_new_conns = self._new_conns.copy() |
| 165 | new_new_conns.add(conn) |
| 166 | self._new_conns = new_new_conns |
| 167 | |
| 168 | def connection_destroyed(self, conn): |
| 169 | with self._conn_set_lock: |