| 421 | callback(*data) |
| 422 | |
| 423 | def _handle_error(self, namespace, data): |
| 424 | namespace = namespace or '/' |
| 425 | self.logger.info('Connection to namespace {} was rejected'.format( |
| 426 | namespace)) |
| 427 | if data is None: |
| 428 | data = tuple() |
| 429 | elif not isinstance(data, (tuple, list)): |
| 430 | data = (data,) |
| 431 | self._trigger_event('connect_error', namespace, *data) |
| 432 | self.failed_namespaces.append(namespace) |
| 433 | self._connect_event.set() |
| 434 | if namespace in self.namespaces: |
| 435 | del self.namespaces[namespace] |
| 436 | if namespace == '/': |
| 437 | self.namespaces = {} |
| 438 | self.connected = False |
| 439 | |
| 440 | def _trigger_event(self, event, namespace, *args): |
| 441 | """Invoke an application event handler.""" |