pub(crate) async fn call_with_retry<R, F, Fut>(
        &self,
        factory: F,
        call_name: &'static str,
    ) -> Result<R>
    where
        F: Fn() -> Fut + Unpin,
        Fut: Future<Output = Result<R>>,
    {
        let rtc = self.get_retry_config(call_name);
        let res = Self::make_future_retry(rtc, factory, call_name).await;
        Ok(res.map_err(|(e, _attempt)| e)?.0)
    }
/// Wraps a call to the underlying client with retry capability.
///
/// This is the "old" path used by higher-level [WorkflowClientTrait] implementors
Wraps a call to the underlying client with retry capability.
This is the "old" path used by higher-level [WorkflowClientTrait] implementors
Wraps a call to the underlying client with retry capability . This is the " old " path used by higher - level [ WorkflowClientTrait ] implementors
pub(crate) async fn call_with_retry<R, F, Fut>(
        &self,
        factory: F,
        call_name: &'static str,
    ) -> Result<R>
    where
        F: Fn() -> Fut + Unpin,
        Fut: Future<Output = Result<R>>,
    {
        let rtc = self.get_retry_config(call_name);
        let res = Self::make_future_retry(rtc, factory, call_name).await;
        Ok(res.map_err(|(e, _attempt)| e)?.0)
    }
pub ( crate ) async fn call_with_retry < R , F , Fut > ( & self , factory : F , call_name : & ' static str , ) -> Result < R > where F : Fn ( ) -> Fut + Unpin , Fut : Future < Output = Result < R > > , { let rtc = self . get_retry_config ( call_name ) ; let res = Self :: make_future_retry ( rtc , factory , call_name ) . await ; Ok ( res . map_err ( | ( e , _attempt ) | e ) ? . 0 ) }
Wraps a call to the underlying client with retry capability.
Wraps a call to the underlying client with retry capability .
&self
factory
F
call_name
&'static str
&self
factory
F
call_name
&'static str