Struct NatsPublisher 

pub struct NatsPublisher { /* private fields */ }

NATS publisher built on top of async_nats::Client. Cheap to clone.

Holds the broker’s shared connection cell, so a publisher created before the broker connects resolves the client on first use; publishing before Broker::connect returns NatsError::NotConnected.

Trait Implementations

impl Clone for NatsPublisher

fn clone(&self) -> NatsPublisher

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for NatsPublisher

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Publisher for NatsPublisher

type Error = NatsError

The error type returned by publish.

async fn publish(&self, msg: OutgoingMessage<'_>) -> Result<(), Self::Error>

Publishes a message to the broker.

impl RequestReply for NatsPublisher

type Reply = NatsMessage

The reply message type.

async fn request( &self, msg: OutgoingMessage<'_>, timeout: Duration, ) -> Result<Self::Reply, Self::Error>

Publishes msg and awaits a single correlated reply, or fails after timeout.