/commonlibrary/rust/ylong_http/ylong_http/src/response/ |
H A D | mod.rs | 26 /// The status-line and field-line of a response-message are stored in 108 use crate::response::Response; 123 let response = Response { in ut_response_version() 127 assert_eq!(response.version().as_str(), "HTTP/1.1") in ut_response_version() 142 let response = Response { in ut_response_status_code() 146 assert_eq!(response.status().as_u16(), 304) in ut_response_status_code() 160 let response = Response { in ut_response_headers() 172 assert_eq!(response.headers(), &headers) in ut_response_headers() 186 let response = Response { in ut_response_body() 190 assert_eq!(*response in ut_response_body() 204 let mut response = Response { ut_response_body_mut() variables [all...] |
/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
H A D | client.rs | 43 /// let response = client.request(request).unwrap(); 46 /// let status = response.status(); 104 /// let response = client.request(Request::new(EmptyBody)); 120 let response = self.send_request_retryable(&mut request); in retry_send_request() 121 if response.is_ok() || retries == 0 { in retry_send_request() 122 return response; in retry_send_request() 132 let response = self.send_request_with_uri(request.uri().clone(), request)?; in send_request_retryable() 133 self.redirect_request(response, request) in send_request_retryable() 138 response: Response<HttpBody>, in redirect_request() 141 let mut response in redirect_request() variables [all...] |
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
H A D | client.rs | 64 /// let response = client.request(request).await?; 67 /// let status = response.status(); 154 /// let response = client 164 let response = self.send_request(request.clone()).await; 165 if let Err(ref err) = response { 172 return response; 179 let mut response = self.send_unformatted_request(request.clone()).await?; variables 180 response = self.redirect(response, request.clone()).await?; 182 self.inner.set_alt_svcs(request, &response); 228 let mut response = response; global() variables [all...] |
H A D | response.rs | 17 use ylong_http::response::Response as Resp; 29 pub(crate) fn new(response: Resp<HttpBody>) -> Self { 30 Self { inner: response }
|
H A D | mod.rs | 34 mod response; modules 57 pub use response::Response;
|
H A D | pool.rs | 84 pub(crate) fn set_alt_svcs(&self, request: RequestArc, response: &Response) { 85 self.alt_svcs.set_alt_svcs(request, response);
|
/commonlibrary/rust/ylong_http/ylong_http_client/tests/ |
H A D | sdv_async_http_proxy.rs | 30 /// 5. The server sends a response message. 31 /// 6. Verifies the received response on the client. 82 let mut response = client.request(request).await.expect("Request send failed"); in sdv_async_client_send_request() variables 85 response.status().as_u16(), in sdv_async_client_send_request() 87 "Assert response status code failed" in sdv_async_client_send_request() 90 response.version().as_str(), in sdv_async_client_send_request() 92 "Assert response version failed" in sdv_async_client_send_request() 95 response in sdv_async_client_send_request() 99 "Get response header \"{}\" failed", in sdv_async_client_send_request() 104 "Convert response heade in sdv_async_client_send_request() [all...] |
H A D | sdv_async_http2.rs | 27 use ylong_http::response::status::StatusCode; 79 let response = hyper::Response::builder() 83 .expect("build hyper response failed"); 84 Ok(response) 183 let mut response = client.request(request).await.expect("get response failed"); in sdv_async_h2_client_send_request() variables 184 assert_eq!(response.status(), StatusCode::OK); in sdv_async_h2_client_send_request() 189 let read = response in sdv_async_h2_client_send_request() 202 "Assert response body data length failed" in sdv_async_h2_client_send_request() 262 let mut response in sdv_async_h2_client_send_request_concurrently() variables [all...] |
/commonlibrary/rust/ylong_http/ylong_http_client/examples/ |
H A D | async_https_outside.rs | 57 let response = client.request(request).await?; 59 println!("{}", response.status().as_u16()); 60 println!("{}", response.headers()); 63 let _ = Downloader::console(response).download().await;
|
H A D | sync_https_outside.rs | 51 let response = client.request(request)?; in req() 53 println!("{}", response.status().as_u16()); in req() 54 println!("{}", response.headers()); in req()
|
H A D | sync_proxy_http.rs | 16 //! response. 32 let mut response = client.request(request)?; in main() variables 34 let _ = BodyReader::default().read_all(response.body_mut()); in main()
|
H A D | sync_redirect_http.rs | 16 //! request, and reading the response. 31 let mut response = client.request(request)?; in main() variables 34 let _ = BodyReader::default().read_all(response.body_mut()); in main()
|
H A D | sync_http.rs | 16 //! response. 31 let mut response = client.request(request)?; in main() variables 34 let _ = BodyReader::default().read_all(response.body_mut()); in main()
|
H A D | async_http_multi.rs | 16 //! request, and reading the response asynchronously. 31 let response = client.request(request).await.unwrap(); in main() 34 let _ = Downloader::console(response).download().await; in main()
|
H A D | async_http.rs | 16 //! request, and reading the response asynchronously. 40 let response = client.request(request).await?; 43 let _ = Downloader::console(response).download().await;
|
H A D | async_certs_adapter.rs | 68 let response = client.request(request).await?; 70 Downloader::console(response).download().await
|
/commonlibrary/rust/ylong_http/ylong_http/src/h1/ |
H A D | mod.rs | 18 pub(crate) mod response; 22 pub use response::ResponseDecoder;
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
H A D | redirect.rs | 17 use ylong_http::response::status::StatusCode; 18 use ylong_http::response::Response; 44 response: &Response<B>, 47 match response.status() { 64 let mut location = response 71 "Illegal location header in response",
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/downloader/ |
H A D | mod.rs | 28 /// A downloader that can help you download the response body. 59 /// # async fn download_and_show_progress_on_console(response: Response) { 61 /// let mut downloader = Downloader::console(response); 73 /// # async fn download_and_show_progress(response: Response) { 100 /// .body(response) 124 /// # async fn download_and_show_progress_on_console(response: Response) { 126 /// let mut downloader = Downloader::console(response); 130 pub fn console(response: Response) -> Downloader<Console> { in console() 131 Self::builder().body(response).console().build() in console() 159 /// # async fn download_response_body(response [all...] |
/commonlibrary/rust/ylong_http/ylong_http_client/tests/tcp_server/ |
H A D | async_utils.rs | 199 let mut response = $client variables 204 assert_eq!(response.status().as_u16(), $status, "Assert response status code failed") ; 205 assert_eq!(response.version().as_str(), $resp_version, "Assert response version failed"); 207 response 210 .expect(format!("Get response header \"{}\" failed", $resp_n).as_str()) 212 .expect(format!("Convert response header \"{}\"into string failed", $resp_n).as_str()), 214 "Assert response header \"{}\" failed", $resp_n, 219 let read = response [all...] |
H A D | sync_utils.rs | 189 let mut response = $client variables 193 assert_eq!(response.status().as_u16(), $status, "Assert response status code failed") ; 194 assert_eq!(response.version().as_str(), $version, "Assert response version failed"); 196 response 199 .expect(format!("Get response header \"{}\" failed", $resp_n).as_str()) 201 .expect(format!("Convert response header \"{}\"into string failed", $resp_n).as_str()), 203 "Assert response header \"{}\" failed", $resp_n, 208 let read = response [all...] |
/commonlibrary/rust/ylong_http/ylong_http_client/tests/common/ |
H A D | async_utils.rs | 344 let mut response = $client variables 349 assert_eq!(response.status().as_u16(), $status, "Assert response status code failed") ; 350 assert_eq!(response.version().as_str(), $version, "Assert response version failed"); 352 response 355 .expect(format!("Get response header \"{}\" failed", $resp_n).as_str()) 357 .expect(format!("Convert response header \"{}\"into string failed", $resp_n).as_str()), 359 "Assert response header \"{}\" failed", $resp_n, 364 let read = response [all...] |
H A D | sync_utils.rs | 347 let mut response = $client variables 350 assert_eq!(response.status().as_u16(), $status, "Assert response status code failed"); 351 assert_eq!(response.version().as_str(), $version, "Assert response version failed"); 353 response 356 .expect(format!("Get response header \"{}\" failed", $resp_n).as_str()) 358 .expect(format!("Convert response header \"{}\"into string failed", $resp_n).as_str()), 360 "Assert response header \"{}\" failed", $resp_n, 365 let read = response [all...] |
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/interceptor/ |
H A D | mod.rs | 18 use ylong_http::response::Response as HttpResp; 87 // TODO add cache and response interceptor. 88 // Is it necessary to add a response interceptor? 110 /// Intercepts the response that is eventually returned. 125 /// Intercepts the response returned by the redirect
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/ |
H A D | lib.rs | 16 //! response. 33 pub use ylong_http::response::status::StatusCode; 34 pub use ylong_http::response::ResponsePart;
|