Struct backon::BlockingRetry
source · pub struct BlockingRetry<B: Backoff, T, E, F: FnMut() -> Result<T, E>, RF = fn(_: &E) -> bool, NF = fn(_: &E, _: Duration)> { /* private fields */ }
Expand description
Retry struct generated by [Retryable
].
Implementations§
source§impl<B, T, E, F, RF, NF> BlockingRetry<B, T, E, F, RF, NF>
impl<B, T, E, F, RF, NF> BlockingRetry<B, T, E, F, RF, NF>
sourcepub fn when<RN: FnMut(&E) -> bool>(
self,
retryable: RN
) -> BlockingRetry<B, T, E, F, RN, NF>
pub fn when<RN: FnMut(&E) -> bool>( self, retryable: RN ) -> BlockingRetry<B, T, E, F, RN, NF>
Set the conditions for retrying.
If not specified, we treat all errors as retryable.
§Examples
use anyhow::Result;
use backon::BlockingRetryable;
use backon::ExponentialBuilder;
fn fetch() -> Result<String> {
Ok("hello, world!".to_string())
}
fn main() -> Result<()> {
let retry = fetch
.retry(&ExponentialBuilder::default())
.when(|e| e.to_string() == "EOF");
let content = retry.call()?;
println!("fetch succeeded: {}", content);
Ok(())
}
sourcepub fn notify<NN: FnMut(&E, Duration)>(
self,
notify: NN
) -> BlockingRetry<B, T, E, F, RF, NN>
pub fn notify<NN: FnMut(&E, Duration)>( self, notify: NN ) -> BlockingRetry<B, T, E, F, RF, NN>
Set to notify for everything retrying.
If not specified, this is a no-op.
§Examples
use std::time::Duration;
use anyhow::Result;
use backon::BlockingRetryable;
use backon::ExponentialBuilder;
fn fetch() -> Result<String> {
Ok("hello, world!".to_string())
}
fn main() -> Result<()> {
let retry = fetch.retry(&ExponentialBuilder::default()).notify(
|err: &anyhow::Error, dur: Duration| {
println!("retrying error {:?} with sleeping {:?}", err, dur);
},
);
let content = retry.call()?;
println!("fetch succeeded: {}", content);
Ok(())
}
sourcepub fn call(self) -> Result<T, E>
pub fn call(self) -> Result<T, E>
Call the retried function.
TODO: implment std::ops::FnOnce
after it stable.
Auto Trait Implementations§
impl<B, T, E, F, RF, NF> Freeze for BlockingRetry<B, T, E, F, RF, NF>
impl<B, T, E, F, RF, NF> RefUnwindSafe for BlockingRetry<B, T, E, F, RF, NF>where
F: FnOnce() + RefUnwindSafe,
B: Unpin + Sync + Send + Iterator<Item = Duration> + RefUnwindSafe,
RF: RefUnwindSafe,
NF: RefUnwindSafe,
impl<B, T, E, F, RF, NF> Send for BlockingRetry<B, T, E, F, RF, NF>
impl<B, T, E, F, RF, NF> Sync for BlockingRetry<B, T, E, F, RF, NF>
impl<B, T, E, F, RF, NF> Unpin for BlockingRetry<B, T, E, F, RF, NF>
impl<B, T, E, F, RF, NF> UnwindSafe for BlockingRetry<B, T, E, F, RF, NF>where
F: FnOnce() + UnwindSafe,
B: Unpin + Sync + Send + Iterator<Item = Duration> + UnwindSafe,
RF: UnwindSafe,
NF: UnwindSafe,
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more