ProducerState faststream.confluent.publisher.state.ProducerState # Bases: Protocol producer property # producer: AsyncConfluentProducer ping async # ping(timeout: float) -> bool Source code in faststream/confluent/publisher/state.py 15async def ping(self, timeout: float) -> bool: ... stop async # stop() -> None Source code in faststream/confluent/publisher/state.py 17async def stop(self) -> None: ... flush async # flush() -> None Source code in faststream/confluent/publisher/state.py 19async def flush(self) -> None: ...