Struct async_nats::Request

pub struct Request { /* private fields */ }

Used for building customized requests.

Implementations

impl Request

pub fn new() -> Request

pub fn payload(self, payload: Bytes) -> Request

Sets the payload of the request. If not used, empty payload will be sent.

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 headers(self, headers: HeaderMap) -> Request

Sets the headers of the requests.

Examples

use std::str::FromStr;
let client = async_nats::connect("demo.nats.io").await?;
let mut headers = async_nats::HeaderMap::new();
headers.insert("X-Example", async_nats::HeaderValue::from_str("Value").unwrap());
let request = async_nats::Request::new()
    .headers(headers)
    .payload("data".into());
client.send_request("service".into(), request).await?;

pub fn timeout(self, timeout: Option<Duration>) -> Request

Sets the custom timeout of the request. Overrides default Client timeout. Setting it to Option::None disables the timeout entirely which might result in deadlock. To use default timeout, simply do not call this function.

Examples

let client = async_nats::connect("demo.nats.io").await?;
let request = async_nats::Request::new()
    .timeout(Some(std::time::Duration::from_secs(15)))
    .payload("data".into());
client.send_request("service".into(), request).await?;

pub fn inbox(self, inbox: String) -> Request

Sets custom inbox for this request. Overrides both customized and default Client Inbox.

Examples

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

Trait Implementations

impl Default for Request

fn default() -> Request

Returns the “default value” for a type.