'Extends the elements in the queue.'

def extend(self, vals):

    with self.redis.pipeline(transaction=False) as pipe:
        for val in vals:
            pipe.lpush(self.key, self._pack(val))
        pipe.execute()
