Skip to content

ProducerState

faststream.confluent.publisher.state.ProducerState #

Bases: Protocol

producer property #

producer

ping async #

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

stop async #

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

flush async #

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