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 
32
33
async def ping(self, timeout: float) -> bool:  # noqa: PLR6301
    return False

stop async #

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

flush async #

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