/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
H A D | client.rs | 14 use ylong_http::request::uri::Uri; 40 /// let request = Request::new(EmptyBody); 43 /// let response = client.request(request).unwrap(); 104 /// let response = client.request(Request::new(EmptyBody)); 106 pub fn request<T: Body>( in request() functions 108 mut request: Request<T>, in request() 110 RequestFormatter::new(&mut request).format()?; in request() 111 self.retry_send_request(request) in request() 116 mut request in retry_send_request() [all...] |
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
H A D | request.rs | 22 request: UnsafeCell<Request>, 26 pub(crate) fn new(request: Request) -> Self { 28 request: UnsafeCell::new(request), 40 pub(crate) fn new(request: Request) -> Self { 42 cell: Arc::new(ReqCell::new(request)), 49 unsafe { &mut *self.cell.request.get() }
|
H A D | redirect.rs | 14 use ylong_http::request::method::Method; 15 use ylong_http::request::uri::Uri; 16 use ylong_http::request::Request; 43 request: &mut Request<A>, 50 let _ = request.headers_mut().remove(header_name); 52 let method = request.method_mut(); 62 info.previous.push(request.uri().clone()); 75 // authority of the origin request to it. 77 let origin = request.uri(); 89 let _ = request [all...] |
H A D | data_ref.rs | 20 use crate::util::request::RequestArc; 27 pub(crate) fn new(request: RequestArc) -> Self { 29 body: Some(request), 42 let request = if let Some(ref mut request) = self.body { 43 request 47 let data = request.ref_mut().body_mut();
|
H A D | normalizer.rs | 14 use ylong_http::request::method::Method; 15 use ylong_http::request::uri::{Scheme, Uri}; 16 use ylong_http::request::Request; 39 // TODO Formatting the uri in the request doesn't seem necessary. 212 use ylong_http::request::method::Method; 213 use ylong_http::request::uri::{Uri, UriBuilder}; 214 use ylong_http::request::Request; 251 /// 3. Checks if the request's header result is correct. 254 let mut request = Request::new("this is a body"); in ut_request_format() variables 255 let request_uri = request in ut_request_format() [all...] |
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
H A D | client.rs | 16 use ylong_http::request::uri::Uri; 23 use crate::async_impl::request::Message; 37 use crate::util::request::RequestArc; 61 /// let request = Request::builder().body(Body::empty())?; 64 /// let response = client.request(request).await?; 155 /// .request(Request::builder().body(Body::empty())?) 160 pub async fn request(&self, request: Request) -> Result<Response, HttpClientError> { 161 let mut request variables [all...] |
H A D | pool.rs | 18 use ylong_http::request::uri::Authority; 20 use ylong_http::request::uri::Scheme; 21 use ylong_http::request::uri::Uri; 41 use crate::util::request::RequestArc; 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/src/request/ |
H A D | mod.rs | 19 //! [http_request]: https://www.rfc-editor.org/rfc/rfc9112.html#request.line 27 //! use ylong_http::request::method::Method; 28 //! use ylong_http::request::{Request, RequestBuilder}; 32 //! let request = Request::builder() 41 //! assert_eq!(request.method(), &Method::GET); 42 //! assert_eq!(request.uri().to_string(), "www.example.com"); 43 //! assert_eq!(request.version(), &Version::HTTP1_1); 45 //! request 69 /// HTTP `Request`. A `Request` consists of a request line and a body. 74 /// use ylong_http::request 755 let mut request = RequestBuilder::new() ut_request_builder_build_2() variables [all...] |
/commonlibrary/rust/ylong_http/ylong_http_client/tests/ |
H A D | sdv_async_http_client_error.rs | 60 /// 2. The client sends a request message that uri is reserved. 68 let request = build_client_request!( in sdv_err_start_connect_timeout() 77 let resp = client.request(request).await; in sdv_err_start_connect_timeout() 87 /// 2. Creates an async::Client with request timeout 1s. 88 /// 3. The client sends a request message. 89 /// 4. Verifies the received request on the server. 90 /// 5. The server sends a response message 1.5s after receiving the request. 127 let request = build_client_request!( in sdv_err_req_timeout() 137 let resp = client.request(reques in sdv_err_req_timeout() [all...] |
H A D | sdv_async_http2.rs | 50 "Assert request method failed" 55 "Assert request version failed" 68 panic!("server read request body data occurs error"); 75 "Assert request body data length failed" 175 let request = Request::builder() in sdv_async_h2_client_send_request() 183 let mut response = client.request(request).await.expect("get response failed"); in sdv_async_h2_client_send_request() 255 let request = Request::builder() in sdv_async_h2_client_send_request_concurrently() 262 let mut response = client.request(request) in sdv_async_h2_client_send_request_concurrently() [all...] |
H A D | sdv_async_http_proxy.rs | 28 /// 3. The client sends a request message. 29 /// 4. Verifies the received request on the server. 72 let request = build_client_request!( in sdv_async_client_send_request() 82 let mut response = client.request(request).await.expect("Request send failed"); in sdv_async_client_send_request()
|
H A D | sdv_async_http_body_io.rs | 27 /// 3. The client sends a request message. 28 /// 4. Verifies the received request on the server. 68 let request = build_client_request!( in sdv_body_chunk_and_trailer() 78 let mut resp = client.request(request).await.unwrap(); in sdv_body_chunk_and_trailer()
|
/commonlibrary/rust/ylong_http/ylong_http_client/examples/ |
H A D | async_certs_adapter.rs | 54 handles.push(ylong_runtime::spawn(request(temp))); in main() 62 async fn request(client: Arc<Client>) -> Result<(), HttpClientError> { 63 let request = Request::builder() 67 // Sends request and receives a `Response`. 68 let response = client.request(request).await?;
|
H A D | sync_proxy_http.rs | 15 //! crate. It demonstrates creating a client, making a request, and reading the 27 let request = Request::get("http://127.0.0.1:3000") in main() 31 // Sends request and receives a `Response`. in main() 32 let mut response = client.request(request)?; in main()
|
H A D | sync_redirect_http.rs | 16 //! request, and reading the response. 26 let request = Request::get("127.0.0.1:3000") in main() 30 // Sends request and receives a `Response`. in main() 31 let mut response = client.request(request)?; in main()
|
H A D | sync_http.rs | 15 //! crate. It demonstrates creating a client, making a request, and reading the 26 let request = Request::get("127.0.0.1:3000") in main() 30 // Sends request and receives a `Response`. in main() 31 let mut response = client.request(request)?; in main()
|
H A D | async_http_multi.rs | 16 //! request, and reading the response asynchronously. 26 let request = Request::builder() in main() 30 // Sends request and receives a `Response`. in main() 31 let response = client.request(request).await.unwrap(); in main()
|
H A D | async_http.rs | 16 //! request, and reading the response asynchronously. 35 let request = Request::builder() 39 // Sends request and receives a `Response`. 40 let response = client.request(request).await?;
|
H A D | sync_https_outside.rs | 46 let request = Request::get("https://www.baidu.com") in req() 50 // Sends request and receives a `Response`. in req() 51 let response = client.request(request)?; in req()
|
H A D | async_https_outside.rs | 52 let request = Request::builder() 56 // Sends request and receives a `Response`. 57 let response = client.request(request).await?;
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/ |
H A D | http1.rs | 21 use ylong_http::request::uri::Scheme; 28 use crate::async_impl::request::Message; 37 pub(crate) async fn request<S>( 49 .intercept_request(message.request.ref_mut())?; 53 message.request.ref_mut(), 59 encode_various_body(message.request.ref_mut(), &mut conn, &mut buf).await?; 93 request: &mut Request, 100 let content_length = request 108 let transfer_encoding = request 116 let body = request [all...] |
/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/conn/ |
H A D | http1.rs | 18 use ylong_http::request::Request; 28 pub(crate) fn request<S, T>( 30 request: &mut Request<T>, 38 // Encodes request. 39 let mut encode_part = Some(RequestEncoder::new(request.part().clone())); 40 let mut encode_body = Some(request.body_mut());
|
H A D | mod.rs | 28 pub(crate) fn request<S, T>( 30 request: &mut Request<T>, 38 Conn::Http1(http1) => http1::request(http1, request),
|
/commonlibrary/rust/ylong_http/ylong_http/src/h1/ |
H A D | mod.rs | 17 mod request; modules 21 pub use request::RequestEncoder;
|
/commonlibrary/rust/ylong_http/ylong_http_client/tests/common/ |
H A D | mod.rs | 232 ylong_http::request::RequestBuilder::new() 287 async fn $server_fn_name(request: hyper::Request<hyper::Body>) -> Result<hyper::Response<hyper::Body>, std::convert::Infallible> { 288 match request.method().as_str() { 292 assert_eq!($method, request.method().as_str(), "Assert request method failed"); 295 request.uri().to_string(), 296 "Assert request host failed", 300 format!("{:?}", request.version()), 301 "Assert request version failed", 305 request [all...] |