Skip to content

RealProducer

faststream.confluent.publisher.state.RealProducer #

RealProducer(producer: AsyncConfluentProducer)
Source code in faststream/confluent/publisher/state.py 
46
47
def __init__(self, producer: "AsyncConfluentProducer") -> None:
    self.producer = producer

producer instance-attribute #

producer = producer

stop async #

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

ping async #

ping(timeout: float) -> bool
Source code in faststream/confluent/publisher/state.py 
55
56
async def ping(self, timeout: float) -> bool:
    return await self.producer.ping(timeout=timeout)

flush async #

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