Home
last modified time | relevance | path

Searched refs:request (Results 1 - 25 of 57) sorted by relevance

123

/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/
H A Dclient.rs14 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 Drequest.rs22 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 Dredirect.rs14 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 Ddata_ref.rs20 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 Dnormalizer.rs14 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 Dclient.rs16 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 Dpool.rs18 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 Dmod.rs19 //! [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 Dsdv_async_http_client_error.rs60 /// 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 Dsdv_async_http2.rs50 "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 Dsdv_async_http_proxy.rs28 /// 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 Dsdv_async_http_body_io.rs27 /// 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 Dasync_certs_adapter.rs54 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 Dsync_proxy_http.rs15 //! 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 Dsync_redirect_http.rs16 //! 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 Dsync_http.rs15 //! 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 Dasync_http_multi.rs16 //! 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 Dasync_http.rs16 //! 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 Dsync_https_outside.rs46 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 Dasync_https_outside.rs52 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 Dhttp1.rs21 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 Dhttp1.rs18 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 Dmod.rs28 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 Dmod.rs17 mod request; modules
21 pub use request::RequestEncoder;
/commonlibrary/rust/ylong_http/ylong_http_client/tests/common/
H A Dmod.rs232 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...]

Completed in 8 milliseconds

123