| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/config/ |
| H A D | client.rs | 16 use crate::util::{Redirect, Retry, Timeout};
22 pub(crate) connect_timeout: Timeout,
23 pub(crate) request_timeout: Timeout,
32 connect_timeout: Timeout::none(),
33 request_timeout: Timeout::none(),
|
| H A D | settings.rs | 172 /// Timeout settings.
177 /// use ylong_http_client::Timeout;
179 /// let timeout = Timeout::none();
182 pub struct Timeout(Option<Duration>); structure names
184 impl Timeout { impls
185 /// Creates a `Timeout` without limiting the timeout.
190 /// use ylong_http_client::Timeout;
192 /// let timeout = Timeout::none();
198 /// Creates a new `Timeout` from the specified number of whole seconds.
203 /// use ylong_http_client::Timeout;
[all...] |
| H A D | connector.rs | 19 use crate::Timeout;
24 pub(crate) timeout: Timeout,
|
| H A D | mod.rs | 26 pub use settings::{Proxy, ProxyBuilder, Redirect, Retry, SpeedLimit, Timeout};
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| H A D | timeout.rs | 44 pub fn timeout<F>(duration: Duration, future: F) -> Timeout<F> in timeout()
49 Timeout::new(future, sleep) in timeout()
55 pub struct Timeout<T> { structure names
60 impl<T> Timeout<T> { impls
61 fn new(value: T, sleep: Sleep) -> Timeout<T> { in new()
66 impl<T> Future for Timeout<T>
98 /// 1. Use timeout to create a Timeout Struct.
109 // Wrap the future with a `Timeout` set to expire in 10 milliseconds. in ut_timeout_test()
116 // Wrap the future with a `Timeout` set to expire in 10 milliseconds. in ut_timeout_test()
132 /// 1. Use timeout to create a Timeout Struc
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| H A D | reader.rs | 20 use crate::util::Timeout;
64 pub(crate) read_timeout: Timeout,
80 read_timeout: Timeout::none(), in new()
91 /// use ylong_http_client::Timeout;
93 /// let reader = BodyReader::new(DefaultBodyProcessor::new()).read_timeout(Timeout::none());
95 pub fn read_timeout(mut self, timeout: Timeout) -> Self { in read_timeout()
226 use crate::util::Timeout;
237 let reader = BodyReader::new(DefaultBodyProcessor).read_timeout(Timeout::none()); in ut_body_reader_read_timeout()
238 assert_eq!(reader.read_timeout, Timeout::none()); in ut_body_reader_read_timeout()
|
| H A D | client.rs | 21 ClientConfig, ConnectorConfig, HttpConfig, HttpVersion, Proxy, Redirect, Timeout,
242 /// use ylong_http_client::Timeout;
244 /// let builder = ClientBuilder::new().request_timeout(Timeout::none());
246 pub fn request_timeout(mut self, timeout: Timeout) -> Self { in request_timeout()
253 /// Default is `Timeout::none()`.
259 /// use ylong_http_client::Timeout;
261 /// let builder = ClientBuilder::new().connect_timeout(Timeout::none());
263 pub fn connect_timeout(mut self, timeout: Timeout) -> Self { in connect_timeout()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/downloader/ |
| H A D | mod.rs | 26 use crate::util::{SpeedLimit, Timeout};
71 /// # use ylong_http_client::{HttpClientError, SpeedLimit, Timeout};
102 /// .timeout(Timeout::none())
210 return err_from_io!(Timeout, std::io::ErrorKind::TimedOut.into()); in check_timeout()
241 pub(crate) timeout: Timeout,
248 timeout: Timeout::none(), in default()
|
| H A D | builder.rs | 16 use crate::util::{SpeedLimit, Timeout};
165 /// Default is `Timeout::none()`.
171 /// # use ylong_http_client::Timeout;
177 /// .timeout(Timeout::none());
180 pub fn timeout(mut self, timeout: Timeout) -> Self { in timeout()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/ |
| H A D | sdv_async_http_client_error.rs | 22 use ylong_http_client::{ErrorKind, HttpClientError, Redirect, Timeout};
41 assert_eq!(ErrorKind::Timeout.as_str(), "Timeout Error"); in sdv_client_error_kind()
64 .connect_timeout(Timeout::from_secs(1)) in sdv_err_start_connect_timeout()
123 .request_timeout(Timeout::from_secs(1)) in sdv_err_req_timeout()
142 "HttpClientError { ErrorKind: Timeout, Cause: Kind(TimedOut) }" in sdv_err_req_timeout()
144 assert_eq!(format!("{}", e), "Timeout Error: timed out"); in sdv_err_req_timeout()
152 Some(ErrorKind::Timeout) in sdv_err_req_timeout()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| H A D | error.rs | 110 Timeout,
117 RecvTimeoutError::Timeout => write!(f, "channel receiving timeout"), in fmt()
147 let try_timeout2 = RecvTimeoutError::Timeout; in ut_test_sync_error_display()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| H A D | client.rs | 31 ClientConfig, ConnectorConfig, HttpConfig, HttpVersion, Proxy, Redirect, Timeout,
198 Err(elapsed) => err_from_other!(Timeout, elapsed),
345 /// use ylong_http_client::Timeout;
347 /// let builder = ClientBuilder::new().request_timeout(Timeout::none());
349 pub fn request_timeout(mut self, timeout: Timeout) -> Self { in request_timeout()
356 /// Default is `Timeout::none()`.
362 /// use ylong_http_client::Timeout;
364 /// let builder = ClientBuilder::new().connect_timeout(Timeout::none());
366 pub fn connect_timeout(mut self, timeout: Timeout) -> Self { in connect_timeout()
965 use crate::{Proxy, Timeout};
[all...] |
| H A D | http_body.rs | 116 return Poll::Ready(err_from_io!(Timeout, std::io::ErrorKind::TimedOut.into())); in poll_data()
136 return Poll::Ready(err_from_msg!(Timeout, "Request timeout")); in poll_trailer()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h3/ |
| H A D | io_manager.rs | 30 Timeout,
94 self.state = IOManagerState::Timeout;
186 IOManagerState::Timeout => {
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | error.rs | 44 ScheduleError::new(ErrorKind::Other, std::sync::mpsc::RecvTimeoutError::Timeout); in sdv_schedule_error_new()
47 "Custom { kind: Other, error: Timeout }" in sdv_schedule_error_new()
|
| H A D | mpsc_test.rs | 90 Err(RecvTimeoutError::Timeout) in sdv_unbounded_send_recv_timeout_test()
175 Err(RecvTimeoutError::Timeout) in sdv_bounded_send_timeout_recv_timeout_test()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/ |
| H A D | error.rs | 241 Timeout,
267 Self::Timeout => "Timeout Error", in as_str()
359 assert_eq!(ErrorKind::Timeout.as_str(), "Timeout Error"); in ut_err_as_str()
411 let error_timeout = HttpClientError::from_str(ErrorKind::Timeout, "error"); in ut_err_from_str()
414 "HttpClientError { ErrorKind: Timeout, Cause: error }" in ut_err_from_str()
416 assert_eq!(format!("{error_timeout}"), "Timeout Error: error"); in ut_err_from_str()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/ |
| H A D | error.rs | 242 ScheduleError::new(ErrorKind::Other, std::sync::mpsc::RecvTimeoutError::Timeout); in ut_schedule_error_new()
245 "Custom { kind: Other, error: Timeout }" in ut_schedule_error_new()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
| H A D | mod.rs | 31 use crate::{HttpClientError, Timeout};
112 timeout: Timeout,
|