use tokio sleep inside async (#25680)
Co-authored-by: Zano <segfaultdoctor@protonmail.com>
This commit is contained in:
parent
ad82fe6372
commit
edefaa437f
|
@ -20,9 +20,9 @@ use {
|
||||||
atomic::{AtomicU64, Ordering},
|
atomic::{AtomicU64, Ordering},
|
||||||
Arc, RwLock,
|
Arc, RwLock,
|
||||||
},
|
},
|
||||||
thread::sleep,
|
|
||||||
time::{Duration, Instant},
|
time::{Duration, Instant},
|
||||||
},
|
},
|
||||||
|
tokio::time::sleep,
|
||||||
};
|
};
|
||||||
|
|
||||||
pub struct HttpSender {
|
pub struct HttpSender {
|
||||||
|
@ -147,7 +147,7 @@ impl RpcSender for HttpSender {
|
||||||
response, too_many_requests_retries, duration
|
response, too_many_requests_retries, duration
|
||||||
);
|
);
|
||||||
|
|
||||||
sleep(duration);
|
sleep(duration).await;
|
||||||
stats_updater.add_rate_limited_time(duration);
|
stats_updater.add_rate_limited_time(duration);
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue