pub struct Retrying<R> { /* private fields */ }Implementations§
Trait Implementations§
Source§impl<Input, Output, R> Runnable<Input, Output> for Retrying<R>
impl<Input, Output, R> Runnable<Input, Output> for Retrying<R>
Source§fn stream<'a>(
&'a self,
input: Input,
) -> BoxStream<'a, Result<StreamEvent, WesichainError>>
fn stream<'a>( &'a self, input: Input, ) -> BoxStream<'a, Result<StreamEvent, WesichainError>>
Retry-on-stream-start: if the stream errors before its first item is emitted,
apply exponential backoff and re-attempt (up to max_attempts).
Once streaming is in progress (first item emitted), errors pass through as-is.
fn invoke<'life0, 'async_trait>(
&'life0 self,
input: Input,
) -> Pin<Box<dyn Future<Output = Result<Output, WesichainError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn batch<'life0, 'async_trait>(
&'life0 self,
inputs: Vec<Input>,
) -> Pin<Box<dyn Future<Output = Vec<Result<Output, WesichainError>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn abatch<'life0, 'async_trait>(
&'life0 self,
inputs: Vec<Input>,
) -> Pin<Box<dyn Future<Output = Vec<Result<Output, WesichainError>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn to_serializable(&self) -> Option<SerializableRunnable>
Auto Trait Implementations§
impl<R> Freeze for Retrying<R>where
R: Freeze,
impl<R> RefUnwindSafe for Retrying<R>where
R: RefUnwindSafe,
impl<R> Send for Retrying<R>where
R: Send,
impl<R> Sync for Retrying<R>where
R: Sync,
impl<R> Unpin for Retrying<R>where
R: Unpin,
impl<R> UnsafeUnpin for Retrying<R>where
R: UnsafeUnpin,
impl<R> UnwindSafe for Retrying<R>where
R: 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