Struct CoalescingClient 

pub struct CoalescingClient { /* private fields */ }

An HTTP client decorator that joins safe, identical requests already in flight.

Only bodyless GET and HEAD requests are coalesced. Cookie-jar identity and proxy selection are part of the key, so distinct sessions and routes never share a fetch. Joined callers of a failed request receive an Other error because HttpClientError is not cloneable; this intentionally loses connect/timeout variant fidelity.

Examples

use std::sync::Arc;
use millipede_http::{CoalescingClient, ReqwestClient};

let inner = Arc::new(ReqwestClient::new()?);
let client = CoalescingClient::new(inner);

Implementations

impl CoalescingClient

pub fn new(inner: Arc<dyn HttpClient>) -> Self

Wraps an HTTP client with in-flight request coalescing.

Trait Implementations

impl Debug for CoalescingClient

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

Formats the value using the given formatter.

impl HttpClient for CoalescingClient

fn send<'life0, 'async_trait>( &'life0 self, request: HttpRequest, ) -> Pin<Box<dyn Future<Output = Result<HttpResponse, HttpClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sends a request and buffers the complete response body.

fn stream<'life0, 'async_trait>( &'life0 self, request: HttpRequest, ) -> Pin<Box<dyn Future<Output = Result<StreamingResponse, HttpClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sends a request and returns a streaming response body.