Struct async_nats::Client

pub struct Client { /* private fields */ }

Client is a Clonable handle to NATS connection. Client should not be created directly. Instead, one of two methods can be used: crate::connect and crate::ConnectOptions::connect

Implementations

impl Client

pub fn server_info(&self) -> ServerInfo

Returns last received info from the server.

Examples

let client = async_nats::connect("demo.nats.io").await?;
println!("info: {:?}", client.server_info());

pub fn is_server_compatible(&self, major: i64, minor: i64, patch: i64) -> bool

Returns true if the server version is compatible with the version components.

Examples

let client = async_nats::connect("demo.nats.io").await?;
assert!(client.is_server_compatible(2, 8, 4));

pub async fn publish(
    &self,
    subject: String,
    payload: Bytes
) -> Result<(), PublishError>

pub async fn publish_with_headers(
    &self,
    subject: String,
    headers: HeaderMap,
    payload: Bytes
) -> Result<(), Error>

pub async fn publish_with_reply(
    &self,
    subject: String,
    reply: String,
    payload: Bytes
) -> Result<(), Error>

pub async fn publish_with_reply_and_headers(
    &self,
    subject: String,
    reply: String,
    headers: HeaderMap,
    payload: Bytes
) -> Result<(), PublishError>

pub async fn request(
    &self,
    subject: String,
    payload: Bytes
) -> Result<Message, Error>

pub async fn request_with_headers(
    &self,
    subject: String,
    headers: HeaderMap,
    payload: Bytes
) -> Result<Message, Error>

Sends the request with headers.

Examples

let client = async_nats::connect("demo.nats.io").await?;
let mut headers = async_nats::HeaderMap::new();
headers.insert("Key", "Value");
client.request_with_headers("service".into(), headers, "data".into()).await?;

pub async fn send_request(
    &self,
    subject: String,
    request: Request
) -> Result<Message, Error>

Sends the request created by the Request.

Examples

let client = async_nats::connect("demo.nats.io").await?;
let request = async_nats::Request::new().payload("data".into());
client.send_request("service".into(), request).await?;

pub fn new_inbox(&self) -> String

Create a new globally unique inbox which can be used for replies.

Examples

let reply = nc.new_inbox();
let rsub = nc.subscribe(reply).await?;

pub async fn subscribe(&self, subject: String) -> Result<Subscriber, Error>

pub async fn queue_subscribe(
    &self,
    subject: String,
    queue_group: String
) -> Result<Subscriber, Error>

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

pub fn connection_state(&self) -> State

Returns the current state of the connection.

Examples

let client = async_nats::connect("demo.nats.io").await?;
println!("connection state: {}", client.connection_state());

Trait Implementations

impl Clone for Client

fn clone(&self) -> Client

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Client

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

Formats the value using the given formatter.