diff --git a/subxt/src/backend/unstable/mod.rs b/subxt/src/backend/unstable/mod.rs index fb1437352d..7a3a380dbd 100644 --- a/subxt/src/backend/unstable/mod.rs +++ b/subxt/src/backend/unstable/mod.rs @@ -474,9 +474,17 @@ impl Backend for UnstableBackend { // with chainHead_follow. let mut finalized_hash: Option = None; + let mut iter_num = 0; + let now = std::time::Instant::now(); + // Now we can attempt to associate tx events with pinned blocks. let tx_stream = futures::stream::poll_fn(move |cx| { loop { + iter_num += 1; + if now.elapsed().as_secs() > 120 { + panic!("iter={:#?}", iter_num); + } + // Bail early if no more tx events; we don't want to keep polling for pinned blocks. if done { return Poll::Ready(None);