Struct ReqwestClient 

pub struct ReqwestClient { /* private fields */ }

Implementations

impl ReqwestClient

pub fn new() -> Self

pub fn user_agent(agent: &str) -> Result<Self>

pub fn proxy_and_user_agent( proxy: Option<Url>, user_agent: &str, ) -> Result<Self>

pub fn proxy_user_agent_and_read_timeout( proxy: Option<Url>, user_agent: &str, read_timeout: Option<Duration>, ) -> Result<Self>

Like ReqwestClient::proxy_and_user_agent, but also applies a per-read idle timeout. read_timeout fires only after that long with no bytes received on a response body and resets on every chunk, so it aborts a silently stalled stream without disturbing a healthy one that merely goes quiet between chunks. Callers streaming long-lived responses (e.g. LLM completions, which can pause for tens of seconds during provider-side reasoning while keep-alive bytes still flow) should size it comfortably above the provider’s keep-alive interval.

Note: on macOS the timeout is measured against a monotonic clock that pauses during system sleep, so it does not fire from a suspend alone; callers that need prompt detection of a connection killed while suspended must re-validate the stream on wake themselves.

Trait Implementations

impl From<Client> for ReqwestClient

fn from(client: Client) -> Self

Converts to this type from the input type.

impl HttpClient for ReqwestClient

fn proxy(&self) -> Option<&Url>

fn user_agent(&self) -> Option<&HeaderValue>

fn send( &self, req: Request<AsyncBody>, ) -> BoxFuture<'static, Result<Response<AsyncBody>>>

fn get( &self, uri: &str, body: AsyncBody, follow_redirects: bool, ) -> Pin<Box<dyn Future<Output = Result<Response<AsyncBody>, Error>> + Send>>

fn post_json( &self, uri: &str, body: AsyncBody, ) -> Pin<Box<dyn Future<Output = Result<Response<AsyncBody>, Error>> + Send>>