Struct async_nats::Connection

pub struct Connection { /* fields omitted */ }

A NATS client connection.

Implementations

impl Connection

pub async fn publish(&self, subject: &str, msg: impl AsRef<[u8]>) -> Result<()>

Publishes a message.

pub async fn publish_request(
    &self,
    subject: &str,
    reply: &str,
    msg: impl AsRef<[u8]>
) -> Result<()>

Publishes a message with a reply subject.

pub fn new_inbox(&self) -> String

Creates a new unique subject for receiving replies.

pub async fn request(
    &self,
    subject: &str,
    msg: impl AsRef<[u8]>
) -> Result<Message>

Publishes a message and waits for the response.

pub async fn request_timeout(
    &self,
    subject: &str,
    msg: impl AsRef<[u8]>,
    timeout: Duration
) -> Result<Message>

Publishes a message and waits for the response or until the timeout duration is reached

pub async fn request_multi(
    &self,
    subject: &str,
    msg: impl AsRef<[u8]>
) -> Result<Subscription>

Publishes a message and returns a subscription for awaiting the response.

pub async fn subscribe(&self, subject: &str) -> Result<Subscription>

Creates a subscription.

pub async fn queue_subscribe(
    &self,
    subject: &str,
    queue: &str
) -> Result<Subscription>

Creates a queue subscription.

pub async fn flush(&self) -> Result<()>

Flushes by performing a round trip to the server.

pub async fn flush_timeout(&self, timeout: Duration) -> Result<()>

Flushes by performing a round trip to the server or times out after a duration of time.

pub async fn rtt(&self) -> Result<Duration>

Calculates the round trip time between this client and the server.

pub fn client_ip(&self) -> Result<IpAddr>

Returns the client IP as known by the most recently connected server.

Supported as of server version 2.1.6.

pub fn client_id(&self) -> u64

Returns the client ID as known by the most recently connected server.

pub async fn drain(&self) -> Result<()>

Unsubscribes all subscriptions and flushes the connection.

Remaining messages can still be received by existing Subscriptions.

pub async fn close(&self) -> Result<()>

Closes the connection.

pub async fn publish_with_reply_or_headers(
    &self,
    subject: &str,
    reply: Option<&str>,
    headers: Option<&Headers>,
    msg: impl AsRef<[u8]>
) -> Result<()>

Publish a message which may have a reply subject or headers set.

Trait Implementations

impl Clone for Connection

fn clone(&self) -> Connection

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Connection

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

Formats the value using the given formatter.