mirrors/ntex
1
0
Fork 0
mirror of https://github.com/ntex-rs/ntex.git synced 2025-04-05 13:57:39 +03:00
Code Issues Projects Releases Packages Wiki Activity

Make connect trait public

Browse source
This commit is contained in:
James Bell 2024-09-17 14:50:50 +00:00
parent 69f150e3f6
commit e0774cbd5d
3 changed files with 16 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

9
ntex/src/http/client/builder.rs
View file

@ -55,6 +55,15 @@ impl ClientBuilder {
self self
} }
/// Use custom connection. Mainly used for mocking connections.
/// # Note
/// This overrides anything set with [`Self::connector`].
pub fn connection(mut self, connection: impl super::connect::Connect + 'static) -> Self
{
self.config.connector = Box::new(connection);
self
}
/// Set request timeout. /// Set request timeout.
/// ///
/// Request timeout is the total time before a response must be received. /// Request timeout is the total time before a response must be received.

2
ntex/src/http/client/connect.rs
View file

@ -20,7 +20,7 @@ where
} }
} }
pub(super) trait Connect: fmt::Debug { pub trait Connect: fmt::Debug {
fn send_request( fn send_request(
&self, &self,
head: RequestHeadType, head: RequestHeadType,

12
ntex/src/http/client/mod.rs
View file

@ -19,7 +19,7 @@
use std::rc::Rc; use std::rc::Rc;
mod builder; mod builder;
mod connect; pub mod connect;
mod connection; mod connection;
mod connector; mod connector;
pub mod error; pub mod error;
@ -74,12 +74,12 @@ pub struct Connect {
pub struct Client(Rc<ClientConfig>); pub struct Client(Rc<ClientConfig>);
#[derive(Debug)] #[derive(Debug)]
pub(crate) struct ClientConfig { pub struct ClientConfig {
pub(self) connector: Box<dyn HttpConnect>, pub(self) connector: Box<dyn HttpConnect>,
pub(self) headers: HeaderMap, pub headers: HeaderMap,
pub(self) timeout: Millis, pub timeout: Millis,
pub(self) response_pl_limit: usize, pub response_pl_limit: usize,
pub(self) response_pl_timeout: Millis, pub response_pl_timeout: Millis,
} }
impl Default for ClientConfig { impl Default for ClientConfig {