Struct NatsPublisher 

pub struct NatsPublisher { /* private fields */ }

The live Core NATS publisher. Cheap to clone.

Exists only from a ConnectedNatsBroker, so it always has a connection. It aliases that connection, though, and may outlive it: after the broker shuts down every publish reports NatsError::Closed instead of silently succeeding against a dead connection.

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

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

Cancel safety

Core NATS publishing is fire-and-forget: the message is handed to the connection’s writer without waiting for the server. Dropping the future may leave the message either sent or unsent, with no way to tell which.

type Error = NatsError

The error type returned by publish.

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.