Skip to content

FakeConsumer

faststream.kafka.testing.FakeConsumer #

start async #

start() -> None
Source code in faststream/kafka/testing.py 
101
102
async def start(self) -> None:
    pass

stop async #

stop() -> None
Source code in faststream/kafka/testing.py 
104
105
async def stop(self) -> None:
    pass

subscribe #

subscribe(*args: Any, **kwargs: Any) -> None
Source code in faststream/kafka/testing.py 
107
108
def subscribe(self, *args: Any, **kwargs: Any) -> None:
    pass