allow list based iterating on XREADGROUP results

2 files changed, 7 insertions, 9 deletions

diff --git a/redis/client.py b/redis/client.py
index c055496..13c01d0 100755
--- a/redis/client.py
+++ b/redis/client.py
@@ -266,13 +266,10 @@ def parse_xclaim(response):
     return stream_list(response)
 
 
-def multi_stream_list(response):
+def parse_xreadgroup(response):
     if response is None:
         return None
-    result = dict()
-    for r in response:
-        result[nativestr(r[0])] = stream_list(r[1])
-    return result
+    return [[nativestr(r[0]), stream_list(r[1])] for r in response]
 
 
 def float_or_none(response):
@@ -413,7 +410,7 @@ class StrictRedis(object):
             int
         ),
         string_keys_to_dict('XREVRANGE XRANGE', stream_list),
-        string_keys_to_dict('XREAD XREADGROUP', multi_stream_list),
+        string_keys_to_dict('XREAD XREADGROUP', parse_xreadgroup),
         {
             'XGROUP CREATE': bool_ok,
             'XGROUP DESTROY': int,
diff --git a/tests/test_commands.py b/tests/test_commands.py
index 70dcbfa..929b4bd 100644
--- a/tests/test_commands.py
+++ b/tests/test_commands.py
@@ -1692,9 +1692,10 @@ class TestStrictCommands(object):
 
         consumer_name = 'captain_jack_sparrow'
 
-        assert sr.xreadgroup(groupname=group_name, consumername=consumer_name,
-                             **{stream_name: '0'}) == {
-                   stream_name: [(b(stamp1), b_message)]}
+        expected_value = [['xgroup_test_stream', [(stamp1, b_message)]]]
+        assert sr.xreadgroup(groupname=group_name,
+                             consumername=consumer_name,
+                             **{stream_name: '0'}) == expected_value
 
         assert sr.xinfo_groups(name=stream_name)[0][b('consumers')] == 1
         sr.xgroup_delconsumer(stream_name, group_name, consumer_name)