Struct Client 

pub struct Client<Req, Resp>
where
    Req: Send + Sync + 'static,
    Resp: Send + Sync + 'static,
{ /* private fields */ }

A client for sending requests and receiving responses.

The client is thread-safe and can be cloned to share across multiple tasks. It supports both single and batch requests, with configurable timeouts.

Type Parameters

• Req: The type of the request, must be Send + Sync + 'static.
• Resp: The type of the response, must be Send + Sync + 'static.

Implementations

impl<Req, Resp> Client<Req, Resp>

where Req: Send + Sync + 'static, Resp: Send + Sync + 'static,

pub async fn request_timeout( &self, req: Req, timeout: Duration, ) -> Result<Resp, Error>

Sends a single request with a custom timeout.

Parameters

• req: The request to send.
• timeout: The maximum duration to wait for a response.

Returns

• Ok(Resp): The response from the server.
• Err(Error): An error if the request fails or times out.

pub async fn request(&self, req: Req) -> Result<Resp, Error>

Sends a single request with the default timeout.

Parameters

• req: The request to send.

Returns

• Ok(Resp): The response from the server.
• Err(Error): An error if the request fails or times out.

pub async fn request_batch_timeout<ReqSeq>( &self, reqs: ReqSeq, timeout: Duration, concurrency: usize, ) -> Result<Vec<Resp>, Error>

where ReqSeq: IntoIterator<Item = Req> + Send + 'static,

Sends a batch of requests with a custom timeout and concurrency limit.

Parameters

• reqs: An iterator of requests to send.
• timeout: The maximum duration to wait for all responses.
• concurrency: The maximum number of concurrent requests.

Returns

• Ok(Vec<Resp>): A vector of responses from the server.
• Err(Error): An error if any request fails or times out.

pub async fn request_batch<ReqSeq>( &self, reqs: ReqSeq, concurrency: usize, ) -> Result<Vec<Resp>, Error>

where ReqSeq: IntoIterator<Item = Req> + Send + 'static,

Sends a batch of requests with the default timeout and a concurrency limit.

Parameters

• reqs: An iterator of requests to send.
• concurrency: The maximum number of concurrent requests.

Returns

• Ok(Vec<Resp>): A vector of responses from the server.
• Err(Error): An error if any request fails or times out.

Trait Implementations

impl<Req, Resp> Clone for Client<Req, Resp>

where Req: Send + Sync + 'static + Clone, Resp: Send + Sync + 'static + Clone,

fn clone(&self) -> Client<Req, Resp>

Returns a duplicate of the value.

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

Performs copy-assignment from source.