

def get(self, *args):
    if args:
        keys = self.get_keys(args)
        pipe = self.redis.pipeline()
        for key in keys:
            pipe.lrange(key, 0, (- 1))
        results = pipe.execute()
        results = [list(map(self.data_type, items)) for items in results]
        return self._to_result(results)

dataset/ETHPy150Open tschellenbach/Stream-Framework/stream_framework/storage/redis/lists_storage.py RedisListsStorage.get/original