feat: add retry notification

LeoPatOZ · LeoPatOZ · commit 8b1079cc306b · 2025-11-04T21:12:16.000+09:00
diff --git a/src/robust_provider.rs b/src/robust_provider.rs
@@ -279,7 +279,12 @@ impl<N: Network> RobustProvider<N> {
 
         match timeout(
             self.max_timeout,
-            (|| operation(provider.clone())).retry(retry_strategy).sleep(tokio::time::sleep),
+            (|| operation(provider.clone()))
+                .retry(retry_strategy)
+                .notify(|err: &RpcError<TransportErrorKind>, dur: Duration| {
+                    info!(error = %err, "RPC error retrying after {:?}", dur);
+                })
+                .sleep(tokio::time::sleep),
         )
         .await
         {

Original file line number	Diff line number	Diff line change
`@@ -279,7 +279,12 @@ impl<N: Network> RobustProvider<N> {`
`279`	`279`
`280`	`280`	`match timeout(`
`281`	`281`	`self.max_timeout,`
`282`		`- (\|\| operation(provider.clone())).retry(retry_strategy).sleep(tokio::time::sleep),`
	`282`	`+ (\|\| operation(provider.clone()))`
	`283`	`+ .retry(retry_strategy)`
	`284`	`+ .notify(\|err: &RpcError<TransportErrorKind>, dur: Duration\| {`
	`285`	`+ info!(error = %err, "RPC error retrying after {:?}", dur);`
	`286`	`+ })`
	`287`	`+ .sleep(tokio::time::sleep),`
`283`	`288`	`)`
`284`	`289`	`.await`
`285`	`290`	`{`