clientix_core/client/asynchronous/
client.rs

1use std::sync::{Arc, Mutex};
2use http::Method;
3use reqwest::Client as ReqwestClient;
4use crate::client::asynchronous::request::AsyncRequestBuilder;
5use crate::client::ClientConfig;
6
7#[derive(Clone)]
8pub struct AsyncClient {
9    pub client: Arc<Mutex<ReqwestClient>>,
10    pub url: String,
11    pub path: String
12}
13
14impl AsyncClient {
15
16    pub fn get(&self) -> AsyncRequestBuilder {
17        AsyncRequestBuilder::builder(self.clone(), Method::GET)
18    }
19
20    pub fn post(&self) -> AsyncRequestBuilder {
21        AsyncRequestBuilder::builder(self.clone(), Method::POST)
22    }
23
24    pub fn put(&self) -> AsyncRequestBuilder {
25        AsyncRequestBuilder::builder(self.clone(), Method::PUT)
26    }
27
28    pub fn delete(&self) -> AsyncRequestBuilder {
29        AsyncRequestBuilder::builder(self.clone(), Method::DELETE)
30    }
31
32}
33
34impl From<ClientConfig> for AsyncClient {
35
36    fn from(config: ClientConfig) -> Self {
37        let mut client = ReqwestClient::builder();
38
39        if let Some(user_agent) = config.user_agent {
40            client = client.user_agent(user_agent.clone());
41        }
42
43        if !config.headers.is_empty() {
44            client = client.default_headers(config.headers.clone());
45        }
46
47        if let Some(timeout) = config.timeout {
48            client = client.timeout(timeout);
49        }
50
51        if let Some(connect_timeout) = config.connect_timeout {
52            client = client.connect_timeout(connect_timeout);
53        }
54
55        client = client.connection_verbose(config.connection_verbose);
56
57        let url = config.url.expect("missing url");
58        let path = config.path.unwrap_or(String::new());
59        let client = Arc::new(Mutex::new(client.build().expect("failed to build async client")));
60
61        AsyncClient { client, url, path }
62    }
63
64}
clientix_core/client/asynchronous/client.rs

clientix_core/client/asynchronous/
client.rs
