Skip to content

Visitor

faststream.redis.testing.Visitor #

Bases: Protocol

visit #

visit(*, channel, list, stream, sub)
Source code in faststream/redis/testing.py 
256
257
258
259
260
261
262
263
def visit(
    self,
    *,
    channel: str | None,
    list: str | None,
    stream: str | None,
    sub: "LogicSubscriber",
) -> str | None: ...

get_message #

get_message(channel, body, sub)
Source code in faststream/redis/testing.py 
265
def get_message(self, channel: str, body: Any, sub: "LogicSubscriber") -> Any: ...