Struct RequestBatcher

pub struct RequestBatcher { /* private fields */ }

HTTP/2 request batcher for CDN downloads

Implementations

impl RequestBatcher

pub fn new(client: Client, config: BatchConfig) -> Self

Create a new request batcher

pub async fn submit_request( &self, request: BatchRequest, ) -> Result<UnboundedReceiver<BatchResponse>>

Submit a request to be batched

Returns a receiver for the response. The request will be batched with others and executed when the batch is full or the timeout expires.

pub async fn submit_requests_and_wait( &self, requests: Vec<BatchRequest>, ) -> Vec<BatchResponse>

Submit multiple requests and wait for all responses

pub async fn get_stats(&self) -> BatchStats

Get current statistics

pub fn create_cdn_requests( cdn_host: &str, path: &str, hashes: &[String], ) -> Vec<BatchRequest>

Create batch requests for CDN file downloads

Trait Implementations

impl Debug for RequestBatcher

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

Formats the value using the given formatter.