automatically connect for blocking reads (asyncio)

Author: kristjanvalur

redis/asyncio/connection.py

@@ -933,6 +933,8 @@ async def can_read(self, timeout: float = 0):
 
     async def read_response(self, disable_decoding: bool = False):
         """Read the response from a previously sent command"""
+        if not self.is_connected:
+            await self.connect()
         try:
             async with self._lock:
                 if self.socket_timeout:

tests/test_asyncio/test_pubsub.py

@@ -775,7 +775,7 @@ def callback(message):
 
 
 # @pytest.mark.xfail
-@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:
     timeout = 2