pub struct AsyncRetryExecWithStats<Policy, BA, AA, OX, F, Fut, SleepImpl, T, E, SleepFut = ()> { /* private fields */ }Expand description
Async retry execution wrapper that also yields RetryStats.
Created by calling .with_stats() on an AsyncRetryExec.
Implementations§
Source§impl<Policy, BA, AA, OX, F, Fut, SleepImpl, T, E, SleepFut> AsyncRetryExecWithStats<Policy, BA, AA, OX, F, Fut, SleepImpl, T, E, SleepFut>where
Policy: PolicyHandle,
Policy::Stop: Stop,
Policy::Wait: Wait,
Policy::Predicate: Predicate<T, E>,
BA: BeforeAttemptHook,
AA: AttemptHook<T, E>,
OX: ExitHook<T, E>,
F: AsyncRetryOp<T, E, Fut>,
Fut: Future<Output = Result<T, E>>,
SleepImpl: Sleeper<Sleep = SleepFut>,
SleepFut: Future<Output = ()>,
impl<Policy, BA, AA, OX, F, Fut, SleepImpl, T, E, SleepFut> AsyncRetryExecWithStats<Policy, BA, AA, OX, F, Fut, SleepImpl, T, E, SleepFut>where
Policy: PolicyHandle,
Policy::Stop: Stop,
Policy::Wait: Wait,
Policy::Predicate: Predicate<T, E>,
BA: BeforeAttemptHook,
AA: AttemptHook<T, E>,
OX: ExitHook<T, E>,
F: AsyncRetryOp<T, E, Fut>,
Fut: Future<Output = Result<T, E>>,
SleepImpl: Sleeper<Sleep = SleepFut>,
SleepFut: Future<Output = ()>,
Sourcepub fn call(
self,
) -> impl Future<Output = (Result<T, RetryError<T, E>>, RetryStats)>
pub fn call( self, ) -> impl Future<Output = (Result<T, RetryError<T, E>>, RetryStats)>
Runs the configured retry loop, returning a future that resolves to the
result paired with RetryStats.
Trait Implementations§
Source§impl<Policy, BA, AA, OX, F, Fut, SleepImpl, T, E, SleepFut> Debug for AsyncRetryExecWithStats<Policy, BA, AA, OX, F, Fut, SleepImpl, T, E, SleepFut>
impl<Policy, BA, AA, OX, F, Fut, SleepImpl, T, E, SleepFut> Debug for AsyncRetryExecWithStats<Policy, BA, AA, OX, F, Fut, SleepImpl, T, E, SleepFut>
impl<'__pin, Policy, BA, AA, OX, F, Fut, SleepImpl, T, E, SleepFut> Unpin for AsyncRetryExecWithStats<Policy, BA, AA, OX, F, Fut, SleepImpl, T, E, SleepFut>where
PinnedFieldsOf<__Origin<'__pin, Policy, BA, AA, OX, F, Fut, SleepImpl, T, E, SleepFut>>: Unpin,
Auto Trait Implementations§
impl<Policy, BA, AA, OX, F, Fut, SleepImpl, T, E, SleepFut = ()> !RefUnwindSafe for AsyncRetryExecWithStats<Policy, BA, AA, OX, F, Fut, SleepImpl, T, E, SleepFut>
impl<Policy, BA, AA, OX, F, Fut, SleepImpl, T, E, SleepFut = ()> !Send for AsyncRetryExecWithStats<Policy, BA, AA, OX, F, Fut, SleepImpl, T, E, SleepFut>
impl<Policy, BA, AA, OX, F, Fut, SleepImpl, T, E, SleepFut = ()> !Sync for AsyncRetryExecWithStats<Policy, BA, AA, OX, F, Fut, SleepImpl, T, E, SleepFut>
impl<Policy, BA, AA, OX, F, Fut, SleepImpl, T, E, SleepFut = ()> !UnwindSafe for AsyncRetryExecWithStats<Policy, BA, AA, OX, F, Fut, SleepImpl, T, E, SleepFut>
impl<Policy, BA, AA, OX, F, Fut, SleepImpl, T, E, SleepFut> Freeze for AsyncRetryExecWithStats<Policy, BA, AA, OX, F, Fut, SleepImpl, T, E, SleepFut>
impl<Policy, BA, AA, OX, F, Fut, SleepImpl, T, E, SleepFut> UnsafeUnpin for AsyncRetryExecWithStats<Policy, BA, AA, OX, F, Fut, SleepImpl, T, E, SleepFut>where
Policy: UnsafeUnpin,
F: UnsafeUnpin,
SleepImpl: UnsafeUnpin,
BA: UnsafeUnpin,
AA: UnsafeUnpin,
OX: UnsafeUnpin,
Fut: UnsafeUnpin,
SleepFut: UnsafeUnpin,
T: UnsafeUnpin,
E: UnsafeUnpin,
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