OMGeeky/google-apis-rs
1
0
Fork 0
mirror of https://github.com/OMGeeky/google-apis-rs.git synced 2025-12-26 17:02:24 +01:00
Code Issues Packages Projects Releases Wiki Activity

Replace std:🧵:sleep with tokio:🧵:sleep

Browse Source
This commit is contained in:
philippeitis
2022-09-30 07:42:11 +00:00
committed by GitHub
parent 276324ae09
commit 811ed3d016
1 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
google-apis-common/src/lib.rs
View File

@@ -5,7 +5,6 @@ use std::future::Future;
use std::io::{self, Cursor, Read, Seek, SeekFrom, Write};
use std::pin::Pin;
use std::str::FromStr;
use std::thread::sleep;
use std::time::Duration;
use itertools::Itertools;
@@ -21,6 +20,7 @@ use mime::{Attr, Mime, SubLevel, TopLevel, Value};
use serde_json as json;
use tokio::io::{AsyncRead, AsyncWrite};
use tokio::time::sleep;
use tower_service;
pub use yup_oauth2 as oauth2;
@@ -597,7 +597,6 @@ where
pub media_type: Mime,
pub content_length: u64,
}
impl<'a, A, S> ResumableUploadHelper<'a, A, S>
where
S: tower_service::Service<Uri> + Clone + Send + Sync + 'static,
@@ -639,7 +638,7 @@ where
}
None | Some(_) => {
if let Retry::After(d) = self.delegate.http_failure(&r, None) {
sleep(d);
sleep(d).await;
continue;
}
return Err(Ok(r));
@@ -649,7 +648,7 @@ where
}
Err(err) => {
if let Retry::After(d) = self.delegate.http_error(&err) {
sleep(d);
sleep(d).await;
continue;
}
return Err(Err(err));
@@ -732,7 +731,7 @@ where
&reconstructed_result,
json::from_str(&res_body_string).ok(),
) {
sleep(d);
sleep(d).await;
continue;
}
}
@@ -740,7 +739,7 @@ where
}
Err(err) => {
if let Retry::After(d) = self.delegate.http_error(&err) {
sleep(d);
sleep(d).await;
continue;
}
return Some(Err(err));