Struct Responder 

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

A responder that processes incoming requests and sends back responses.

The responder supports both fixed and dynamic concurrency strategies.

Type Parameters

• Req: The type of the request, must be Send + Sync + 'static.
• Resp: The type of the response, must be Send + Sync + 'static.
• Fut: The future returned by the request handler.
• F: The type of the request handler function.

Implementations

impl<Req, Resp> Responder<Req, Resp>

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

pub async fn process_requests_with_strategy( self, strategy: ConcurrencyStrategy, ) -> Result<(), Error>

Processes incoming requests using the specified concurrency strategy.

Parameters

• strategy: The concurrency strategy to use (Fixed or Dynamic).

Returns

• Ok(()): If all requests are processed successfully.
• Err(Error): If an error occurs during processing.

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

Processes incoming requests with a fixed concurrency of 16.

Returns

• Ok(()): If all requests are processed successfully.
• Err(Error): If an error occurs during processing.

pub async fn process_requests_fixed( self, concurrency: usize, ) -> Result<(), Error>

Processes incoming requests with a fixed concurrency.

Parameters

• concurrency: The number of concurrent requests to process.

Returns

• Ok(()): If all requests are processed successfully.
• Err(Error): If an error occurs during processing.

pub async fn process_requests_dynamic( self, initial_concurrency: usize, max_concurrency: usize, ) -> Result<(), Error>

Processes incoming requests with dynamic concurrency adjustment.

The concurrency is adjusted based on the response time of requests.

Parameters

• initial_concurrency: The initial number of concurrent requests.
• max_concurrency: The maximum number of concurrent requests.

Returns

• Ok(()): If all requests are processed successfully.
• Err(Error): If an error occurs during processing.