Skip to content

FakeConsumer

faststream.kafka.testing.FakeConsumer #

start async #

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

stop async #

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

subscribe #

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