Skip to content

FakeConsumer

faststream.kafka.testing.FakeConsumer #

start async #

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

stop async #

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

subscribe #

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