diff --git a/src/event_source.rs b/src/event_source.rs index a18ee1a..b9c4c23 100644 --- a/src/event_source.rs +++ b/src/event_source.rs @@ -184,7 +184,7 @@ impl<'a> EventSourceProjection<'a> { fn handle_error(&mut self, error: &Error) { self.clear_fetch(); if let Some(retry_delay) = self.retry_policy.retry(error, *self.last_retry) { - let retry_num = self.last_retry.map(|retry| retry.0).unwrap_or(1); + let retry_num = self.last_retry.map(|retry| retry.0.saturating_add(1)).unwrap_or(1); *self.last_retry = Some((retry_num, retry_delay)); self.delay.replace(Delay::new(retry_delay)); } else {