diff --git a/subxt/src/backend/unstable/mod.rs b/subxt/src/backend/unstable/mod.rs
index 7a6b9ca765..f59c11a943 100644
--- a/subxt/src/backend/unstable/mod.rs
+++ b/subxt/src/backend/unstable/mod.rs
@@ -728,7 +728,7 @@ where
 {
     loop {
         let reconnected = follow_handle.reconnected().fuse();
-        let action = retry(|| fun()).fuse();
+        let action = retry(&mut fun).fuse();
 
         pin_mut!(reconnected, action);