Skip to content

FakeConsumer

faststream.kafka.testing.FakeConsumer #

start async #

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

stop async #

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

subscribe #

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