add optional "timeout" parameter to pubsub.can_read

1 files changed, 2 insertions, 2 deletions

diff --git a/redis/connection.py b/redis/connection.py
index 2d666fb..9afae80 100755
--- a/redis/connection.py
+++ b/redis/connection.py
@@ -555,13 +555,13 @@ class Connection(object):
         "Pack and send a command to the Redis server"
         self.send_packed_command(self.pack_command(*args))
 
-    def can_read(self):
+    def can_read(self, timeout=0):
         "Poll the socket to see if there's data that can be read."
         sock = self._sock
         if not sock:
             self.connect()
             sock = self._sock
-        return bool(select([sock], [], [], 0)[0]) or self._parser.can_read()
+        return self._parser.can_read() or bool(select([sock], [], [], timeout)[0])
 
     def read_response(self):
         "Read the response from a previously sent command"