summaryrefslogtreecommitdiff
path: root/redis/client.py
diff options
context:
space:
mode:
authorAndy McCurdy <andy@andymccurdy.com>2018-10-31 08:32:17 -0700
committerAndy McCurdy <andy@andymccurdy.com>2018-10-31 08:32:17 -0700
commit618deba4daed183e9e9734b18bbac44523b68fd6 (patch)
tree58e7b34ccd547b12f577feb2d071763a6d65a707 /redis/client.py
parent0bb9ab9f57f708b5c32c8e70bdbf19f92fc3e49f (diff)
downloadredis-py-618deba4daed183e9e9734b18bbac44523b68fd6.tar.gz
reorganize stream tests
Diffstat (limited to 'redis/client.py')
-rwxr-xr-xredis/client.py8
1 files changed, 4 insertions, 4 deletions
diff --git a/redis/client.py b/redis/client.py
index c5e769d..1ef2ace 100755
--- a/redis/client.py
+++ b/redis/client.py
@@ -232,7 +232,7 @@ def int_or_none(response):
return int(response)
-def stream_list(response):
+def parse_stream_list(response):
if response is None:
return None
return [(r[0], pairs_to_dict(r[1])) for r in response]
@@ -263,13 +263,13 @@ def parse_list_of_recursive_dicts(response):
def parse_xclaim(response):
if all(isinstance(r, (basestring, bytes)) for r in response):
return response
- return stream_list(response)
+ return parse_stream_list(response)
def parse_xread(response):
if response is None:
return []
- return [[nativestr(r[0]), stream_list(r[1])] for r in response]
+ return [[nativestr(r[0]), parse_stream_list(r[1])] for r in response]
def parse_xpending(response, **options):
@@ -465,7 +465,7 @@ class StrictRedis(object):
zset_score_pairs
),
string_keys_to_dict('ZRANK ZREVRANK', int_or_none),
- string_keys_to_dict('XREVRANGE XRANGE', stream_list),
+ string_keys_to_dict('XREVRANGE XRANGE', parse_stream_list),
string_keys_to_dict('XREAD XREADGROUP', parse_xread),
string_keys_to_dict('BGREWRITEAOF BGSAVE', lambda r: True),
{