(self, r)
| 1029 | assert self.message == self.make_message("smessage", self.channel, new_data) |
| 1030 | |
| 1031 | def test_context_manager(self, r): |
| 1032 | with r.pubsub() as pubsub: |
| 1033 | pubsub.subscribe("foo") |
| 1034 | assert pubsub.connection is not None |
| 1035 | |
| 1036 | assert pubsub.connection is None |
| 1037 | assert pubsub.channels == {} |
| 1038 | assert pubsub.patterns == {} |
| 1039 | |
| 1040 | |
| 1041 | class TestPubSubRedisDown: |