diff options
author | Andy McCurdy <andy@andymccurdy.com> | 2018-10-31 08:32:17 -0700 |
---|---|---|
committer | Andy McCurdy <andy@andymccurdy.com> | 2018-10-31 08:32:17 -0700 |
commit | 618deba4daed183e9e9734b18bbac44523b68fd6 (patch) | |
tree | 58e7b34ccd547b12f577feb2d071763a6d65a707 /redis/client.py | |
parent | 0bb9ab9f57f708b5c32c8e70bdbf19f92fc3e49f (diff) | |
download | redis-py-618deba4daed183e9e9734b18bbac44523b68fd6.tar.gz |
reorganize stream tests
Diffstat (limited to 'redis/client.py')
-rwxr-xr-x | redis/client.py | 8 |
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), { |