guarentee consistency by mapping the keys/values with one call

1 files changed, 3 insertions, 2 deletions

diff --git a/redis/client.py b/redis/client.py
index 45f1ff0..15be7b8 100755
--- a/redis/client.py
+++ b/redis/client.py
@@ -1993,8 +1993,9 @@ class StrictRedis(object):
         if not isinstance(streams, dict) or len(streams) == 0:
             raise RedisError('XREAD streams must be a non empty dict')
         pieces.append(Token.get_token('STREAMS'))
-        pieces.extend(streams.keys())
-        pieces.extend(streams.values())
+        keys, values = izip(*iteritems(streams))
+        pieces.extend(keys)
+        pieces.extend(values)
         return self.execute_command('XREAD', *pieces)
 
     def xreadgroup(self, groupname, consumername, streams, count=None,