Struct nats::asynk::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_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.