Skip to content

EmptyProducerState

faststream.confluent.publisher.state.EmptyProducerState #

producer property #

producer: AsyncConfluentProducer

ping async #

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

stop async #

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

flush async #

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