

def remove(self, **kwargs):
    if kwargs:
        pipe = self.redis.pipeline()
        for (list_name, values) in six.iteritems(kwargs):
            key = self.get_key(list_name)
            for value in values:
                pipe.lrem(key, 0, value)
        pipe.execute()

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