forky_fs 0.2.0

Rust Utilities
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use std::ops::AsyncFn;
use tokio::time::sleep;
use tokio::time::Duration;

pub async fn retry_async<T, E>(
	func: impl AsyncFn() -> Result<T, E>,
	timeout: Duration,
) -> Result<T, E> {
	let start = std::time::Instant::now();
	loop {
		match func().await {
			Ok(val) => return Ok(val),
			Err(err) => {
				if start.elapsed() > timeout {
					return Err(err);
				}
			}
		}
		sleep(Duration::from_millis(10)).await;
	}
}