fix automatic connect on blocking pubsub read (non-async)

Author: kristjanvalur

redis/connection.py

@@ -815,6 +815,8 @@ def can_read(self, timeout=0):
 
     def read_response(self, disable_decoding=False):
         """Read the response from a previously sent command"""
+        if not self._sock:
+            self.connect()
         try:
             hosterr = f"{self.host}:{self.port}"
         except AttributeError:

tests/test_pubsub.py

@@ -613,7 +613,7 @@ def test_pubsub_deadlock(self, master_host):
 
 
 @pytest.mark.timeout(5, method="thread")
-@pytest.mark.parametrize("method", ["get_message", pytest.param("listen", marks=pytest.mark.xfail)])
+@pytest.mark.parametrize("method", ["get_message", "listen"])
 @pytest.mark.onlynoncluster
 class TestPubSubAutoReconnect:
     def mysetup(self, r, method):