(self, r)
| 1040 | |
| 1041 | class TestPubSubRedisDown: |
| 1042 | def test_channel_subscribe(self, r): |
| 1043 | r = redis.Redis(host="localhost", port=6390) |
| 1044 | p = r.pubsub() |
| 1045 | with pytest.raises(ConnectionError): |
| 1046 | p.subscribe("foo") |
| 1047 | |
| 1048 | |
| 1049 | class TestPubSubSubcommands: |