Skip to content

NatsFastProducer

faststream.nats.publisher.producer.NatsFastProducer #

Bases: ProducerProto[NatsPublishCommand]

connect #

connect(connection, serializer)
Source code in faststream/nats/publisher/producer.py 
35
36
37
38
39
def connect(
    self,
    connection: Any,
    serializer: Optional["SerializerProto"],
) -> None: ...

disconnect #

disconnect()
Source code in faststream/nats/publisher/producer.py 
41
def disconnect(self) -> None: ...

publish abstractmethod async #

publish(cmd)
Source code in faststream/nats/publisher/producer.py 
43
44
@abstractmethod
async def publish(self, cmd: "NatsPublishCommand") -> Optional["PubAck"]: ...

request abstractmethod async #

request(cmd)
Source code in faststream/nats/publisher/producer.py 
46
47
@abstractmethod
async def request(self, cmd: "NatsPublishCommand") -> "Msg": ...

publish_batch async #

publish_batch(cmd)
Source code in faststream/nats/publisher/producer.py 
49
50
51
async def publish_batch(self, cmd: "NatsPublishCommand") -> None:
    msg = "NATS doesn't support publishing in batches."
    raise FeatureNotSupportedException(msg)