Skip to content

get_pipe

faststream.redis.annotations.get_pipe async #

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