Skip to content

FakeConsumer

faststream.redis.message.FakeConsumer #

Bases: ConsumerProtocol

A fake Redis consumer.

xack async #

xack(name: str, groupname: str, *ids: bytes) -> None
Source code in faststream/redis/message.py 
143
144
async def xack(self, name: str, groupname: str, *ids: bytes) -> None:
    pass

xdel async #

xdel(name: str, *ids: bytes) -> None
Source code in faststream/redis/message.py 
146
147
async def xdel(self, name: str, *ids: bytes) -> None:
    pass

xpending_range async #

xpending_range(
    name: str,
    groupname: str,
    min: bytes,
    max: bytes,
    count: int,
) -> list[dict[str, Any]]
Source code in faststream/redis/message.py 
149
150
151
152
async def xpending_range(  # ruff: ignore[no-self-use]
    self, name: str, groupname: str, min: bytes, max: bytes, count: int
) -> list[dict[str, Any]]:
    return []