OpenSource/teloxide
OpenSource/teloxide
1
0
Fork 0
mirror of https://github.com/teloxide/teloxide.git synced 2025-03-14 11:44:04 +01:00
Code Issues Projects Releases Packages Wiki Activity

Revert buggy "better timeouts"

Browse source
This commit is contained in:
Maybe Waffle 2022-03-03 01:43:25 +03:00
parent 3f2906df62
commit 812f6ef45e
1 changed files with 10 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
src/net/request.rs
View file

@ -16,7 +16,7 @@ pub async fn request_multipart<T>(
api_url: reqwest::Url,
method_name: &str,
params: reqwest::multipart::Form,
timeout_hint: Option<Duration>,
_timeout_hint: Option<Duration>,
) -> ResponseResult<T>
where
T: DeserializeOwned,
@ -40,9 +40,10 @@ where
.build()
.map_err(RequestError::Network)?;
if let Some(timeout) = timeout_hint {
*request.timeout_mut().get_or_insert(Duration::ZERO) += timeout;
}
// FIXME: uncomment this, when reqwest starts setting default timeout early
// if let Some(timeout) = timeout_hint {
// *request.timeout_mut().get_or_insert(Duration::ZERO) += timeout;
// }
let response = client
.execute(request)
@ -58,7 +59,7 @@ pub async fn request_json<T>(
api_url: reqwest::Url,
method_name: &str,
params: Vec<u8>,
timeout_hint: Option<Duration>,
_timeout_hint: Option<Duration>,
) -> ResponseResult<T>
where
T: DeserializeOwned,
@ -83,9 +84,10 @@ where
.build()
.map_err(RequestError::Network)?;
if let Some(timeout) = timeout_hint {
*request.timeout_mut().get_or_insert(Duration::ZERO) += timeout;
}
// FIXME: uncomment this, when reqwest starts setting default timeout early
// if let Some(timeout) = timeout_hint {
// *request.timeout_mut().get_or_insert(Duration::ZERO) += timeout;
// }
let response = client
.execute(request)