Struct HttpClient 

pub struct HttpClient { /* private fields */ }

High-level HTTP client that applies options, header injection, logging, and timeouts.

Implementations

impl HttpClient

pub fn options(&self) -> &HttpClientOptions

Returns a reference to the client options (timeouts, proxy, logging, etc.).

Returns

Immutable borrow of HttpClientOptions.

pub fn add_header_injector(&mut self, injector: HeaderInjector)

Appends a HeaderInjector so its mutation function runs on every request.

Parameters

• injector: Injector to append (order is preserved).

Returns

Nothing.

pub fn add_async_header_injector(&mut self, injector: AsyncHeaderInjector)

Appends an async header injector whose mutation runs after sync injectors.

Parameters

• injector: Async injector to append (order is preserved).

Returns

Nothing.

pub fn add_request_interceptor(&mut self, interceptor: RequestInterceptor)

Appends a request interceptor applied before each request attempt.

Parameters

• interceptor: Request interceptor to append (order is preserved).

pub fn add_response_interceptor(&mut self, interceptor: ResponseInterceptor)

Appends a response interceptor applied on successful responses.

Parameters

• interceptor: Response interceptor to append (order is preserved).

pub fn add_header(&mut self, name: &str, value: &str) -> HttpResult<&mut Self>

Validates and adds one client-level default header.

The header is applied to every request before header injectors and request-level headers.

Parameters

• name: Header name.
• value: Header value.

Returns

Ok(self) after the header is stored.

Errors

Returns [HttpError] when the header name or value is invalid.

pub fn add_headers<'a, I>(&mut self, headers: I) -> HttpResult<&mut Self>

where I: IntoIterator<Item = (&'a str, &'a str)>,

Validates and adds many client-level default headers atomically.

If any input pair is invalid, no header from this batch is applied.

Parameters

• headers: Iterator of (name, value) pairs.

Returns

Ok(self) after all headers are stored.

Errors

Returns [HttpError] when any name/value pair is invalid (nothing from this call is applied).

pub fn clear_header_injectors(&mut self)

Removes all registered header injectors.

Returns

Nothing.

pub fn clear_async_header_injectors(&mut self)

Removes all registered async header injectors.

Returns

Nothing.

pub fn clear_request_interceptors(&mut self)

Removes all registered request interceptors.

pub fn clear_response_interceptors(&mut self)

Removes all registered response interceptors.

pub fn request(&self, method: Method, path: &str) -> HttpRequestBuilder

Starts building an HttpRequest with the given method and path (relative or absolute URL string).

Parameters

• method: HTTP verb (GET, POST, …).
• path: Path relative to HttpClientOptions::base_url or a full URL string.

Returns

A fresh HttpRequestBuilder not yet tied to this client until HttpRequestBuilder::build and HttpClient::execute.

pub async fn execute(&self, request: HttpRequest) -> HttpResult<HttpResponse>

Sends the request and returns a unified HttpResponse.

Parameters

• request: Built request (URL resolved against base_url if path is not absolute).

Returns

• Ok(HttpResponse) when the HTTP status is success (http::StatusCode::is_success).
• Err(HttpError) on URL/header errors, transport failure, timeout, or non-success status.

pub fn execute_sse_with_reconnect( &self, request: HttpRequest, reconnect_options: SseReconnectOptions, ) -> SseEventStream

Opens an SSE stream and reconnects automatically on retryable stream failures.

Reconnect behavior:

• retryable transport/read failures trigger reconnects;
• optional reconnect on clean EOF (reconnect_on_eof);
• Last-Event-ID is set from the latest parsed SSE id: field;
• optional use of SSE retry: as next reconnect delay.

Parameters

• request: SSE request template reused on reconnect.
• reconnect_options: Reconnect limits and delay policy.

Returns

SSE event stream yielding events from one or more reconnect sessions.

Errors

Per-item stream errors include:

• initial stream-open failures (when not reconnectable or retries exhausted);
• SSE protocol errors (non-reconnectable by default);
• transport/read errors after reconnect budget is exhausted.

Trait Implementations

impl Clone for HttpClient

fn clone(&self) -> HttpClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HttpClient

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

Formats the client for debugging (exposes options and injectors; omits the backend client).

Parameters

• f: Destination formatter.

Returns

fmt::Result from writing the debug struct.

Errors

Returns an error if formatting to f fails.