From 4b4a9dfb21170ad141458ddab98084e3793ec605 Mon Sep 17 00:00:00 2001 From: Marko Atanasievski Date: Fri, 8 Nov 2024 20:47:52 +0100 Subject: [PATCH] fix: follow from block interval (#789) * fix: follow from block interval * fix: printout --- zero/src/block_interval.rs | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/zero/src/block_interval.rs b/zero/src/block_interval.rs index 27d03fe3c..a8f1f0b95 100644 --- a/zero/src/block_interval.rs +++ b/zero/src/block_interval.rs @@ -147,7 +147,8 @@ impl BlockInterval { match self { BlockInterval::FollowFrom { start_block } => Ok(Box::pin(try_stream! { let mut current = start_block; - loop { + yield (current, false); + loop { let last_block_number = provider.latest_block_number().await.map_err(|e| { anyhow!("could not retrieve latest block number from the provider: {e}") })?; @@ -156,7 +157,8 @@ impl BlockInterval { current += 1; yield (current, false); } else { - info!("Waiting for the new blocks to be mined, requested block number: {current}, \ + let next = current + 1; + info!("Waiting for the new blocks to be mined, expected block number: {next}, \ latest block number: {last_block_number}"); // No need to poll the node too frequently, waiting // a block time interval for a block to be mined should be enough