Return a Publish/Subscribe object. With this object, you can subscribe to channels and listen for messages that get published to them.
(self, **kwargs)
| 684 | ) |
| 685 | |
| 686 | def pubsub(self, **kwargs): |
| 687 | """ |
| 688 | Return a Publish/Subscribe object. With this object, you can |
| 689 | subscribe to channels and listen for messages that get published to |
| 690 | them. |
| 691 | """ |
| 692 | return PubSub( |
| 693 | self.connection_pool, event_dispatcher=self._event_dispatcher, **kwargs |
| 694 | ) |
| 695 | |
| 696 | def keyspace_notifications( |
| 697 | self, |