include confirmed blocks

iotaledger · May 13, 2024 · 973b8d7 · 973b8d7
1 parent 4a0ff69
commit 973b8d7
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/tangle/slot_stream.rs b/src/tangle/slot_stream.rs
@@ -51,7 +51,10 @@ impl<'a, I: InputSource> Slot<'a, I> {
             .accepted_blocks(self.index())
             .await?
             .try_filter(|block_with_metadata| {
-                futures::future::ready(block_with_metadata.metadata.block_state == Some(BlockState::Finalized))
+                futures::future::ready(
+                    block_with_metadata.metadata.block_state == Some(BlockState::Confirmed)
+                        || block_with_metadata.metadata.block_state == Some(BlockState::Finalized),
+                )
             })
             .and_then(|res| async {
                 let transaction = if let Some(transaction_id) = res