Disconnect the pubsub connection.
(self)
| 3366 | return self.node.redis_connection |
| 3367 | |
| 3368 | def disconnect(self): |
| 3369 | """ |
| 3370 | Disconnect the pubsub connection. |
| 3371 | """ |
| 3372 | if self.connection: |
| 3373 | self.connection.disconnect() |
| 3374 | for pubsub in self.node_pubsub_mapping.values(): |
| 3375 | if pubsub.connection: |
| 3376 | pubsub.connection.disconnect() |
| 3377 | |
| 3378 | |
| 3379 | class ClusterPipeline(RedisCluster): |
no outgoing calls
no test coverage detected