From 973b8d756015685a63d62d1a441f2ea720dcacb3 Mon Sep 17 00:00:00 2001
From: Alexander Schmidt <alexander.schmidt@iota.org>
Date: Mon, 13 May 2024 14:31:11 +0200
Subject: [PATCH] include confirmed blocks

---
 src/tangle/slot_stream.rs | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/src/tangle/slot_stream.rs b/src/tangle/slot_stream.rs
index 5a18ac6a5..6b602e4aa 100644
--- 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