retry_fn
Function for executing retry either as a closure with a std-based sleep (thread::sleep) or
using either of the most popular async runtime's. Tokio or async-std. Inspired by the other
retry libraries out there, this is up-to-date and combines features from several.
Sync Example
```rust
use std::{io, time::Duration};
use retry_fn::{retry, RetryResult, strategy::ExponentialBackoff};
fn main() -> Result<(), Box> {
let mut count = 0;
let res = retry(ExponentialBackoff::new(Duration::fromsecs(2)), |op| {
if op.retries >= 3 {
RetryResult::<&str, _>::Err(io::Error::new(
io::ErrorKind::TimedOut,
"timed out",
))
} else {
count += 1;
RetryResult::Retry()
}
});
asserteq!(count, 3);
assert!(res.is_err());
Ok(())
}
```
Using tokio
Enable the tokio-runtime feature to get access to this function
```rust
use std::{io, sync::{Arc, Mutex}};
use retry_fn::{tokio::retry, RetryResult, strategy::Constant};
[tokio::main]
async fn main() -> Result<(), Box> {
let count: Arc> = Arc::new(Mutex::new(0));
let res = retry(Constant::frommillis(100), |op| {
let count = count.clone();
async move {
if op.retries >= 3 {
RetryResult::<&str, _>::Err(io::Error::new(
io::ErrorKind::TimedOut,
"timed out",
))
} else {
*count.lock().unwrap() += 1;
RetryResult::Retry()
}
}
})
.await;
asserteq!(*count.lock().unwrap(), 3);
assert!(res.is_err());
Ok(())
}
```