(self)
| 1029 | pass |
| 1030 | |
| 1031 | def reset(self) -> None: |
| 1032 | if self.connection: |
| 1033 | self.connection.disconnect() |
| 1034 | self.connection.deregister_connect_callback(self.on_connect) |
| 1035 | self.connection_pool.release(self.connection) |
| 1036 | self.connection = None |
| 1037 | self.health_check_response_counter = 0 |
| 1038 | self.channels = {} |
| 1039 | self.pending_unsubscribe_channels = set() |
| 1040 | self.shard_channels = {} |
| 1041 | self.pending_unsubscribe_shard_channels = set() |
| 1042 | self.patterns = {} |
| 1043 | self.pending_unsubscribe_patterns = set() |
| 1044 | self.subscribed_event.clear() |
| 1045 | |
| 1046 | def close(self) -> None: |
| 1047 | self.reset() |
no test coverage detected