Skip to content

get_pipe

faststream.redis.annotations.get_pipe async #

get_pipe(redis)
Source code in faststream/redis/annotations.py 
36
37
38
async def get_pipe(redis: Redis) -> AsyncIterator[RedisPipeline]:
    async with redis.pipeline() as pipe:
        yield pipe