Struct RetryLoop 

pub struct RetryLoop { /* private fields */ }

Drives the retry loop for a single RPC call.

Create one per call, then call advance after every failure.

let mut rl = RetryLoop::new(Arc::clone(&self.inner.retry_policy));
loop {
match self.do_rpc_call(req).await {
    Ok(body) => return Ok(body),
    Err(e)   => rl.advance(e).await?,
}
}

advance either:

• sleeps the required duration and returns Ok(()) → caller should retry, or
• returns Err(e) → caller should propagate.

This is the single source of truth; previously the same loop was copy-pasted into rpc_call_raw, rpc_write, and the reconnect path.

Implementations

impl RetryLoop

pub fn new(policy: Arc<dyn RetryPolicy>) -> Self

pub async fn advance( &mut self, err: InvocationError, ) -> Result<(), InvocationError>

Record a failure and either sleep+return-Ok (retry) or return-Err (give up).

Mutates self to track cumulative state across retries.