fix: Ensure while loop terminates with error instead of skipping

near · Jul 16, 2024 · 6a2bcf8 · 6a2bcf8
1 parent 9aa9500
commit 6a2bcf8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/block-streamer/src/block_stream.rs b/block-streamer/src/block_stream.rs
@@ -269,7 +269,7 @@ async fn process_bitmap_indexer_blocks(
 
     let mut last_published_block_height: u64 = start_block_height;
 
-    while let Some(Ok(block_height)) = matching_block_heights.next().await {
+    while let Some(block_height) = matching_block_heights.next().await.transpose()? {
         redis
             .publish_block(indexer, redis_stream.clone(), block_height, MAX_STREAM_SIZE)
             .await?;