Skip to content

EmptyProducerState

faststream.confluent.publisher.state.EmptyProducerState #

producer property #

producer

ping async #

ping(timeout)
Source code in faststream/confluent/publisher/state.py 
30
31
async def ping(self, timeout: float) -> bool:
    return False

stop async #

stop()
Source code in faststream/confluent/publisher/state.py 
36
37
async def stop(self) -> None:
    pass

flush async #

flush()
Source code in faststream/confluent/publisher/state.py 
39
40
async def flush(self) -> None:
    pass