diff --git a/crates/engine/tree/src/tree/payload_processor/mod.rs b/crates/engine/tree/src/tree/payload_processor/mod.rs index 57a9d1a0ec..d0dbbb3d05 100644 --- a/crates/engine/tree/src/tree/payload_processor/mod.rs +++ b/crates/engine/tree/src/tree/payload_processor/mod.rs @@ -822,9 +822,7 @@ impl PayloadHandle { /// Returns iterator yielding transactions from the stream. pub fn iter_transactions(&mut self) -> impl Iterator> + '_ { - core::iter::repeat_with(|| self.transactions.recv()) - .take_while(|res| res.is_ok()) - .map(|res| res.unwrap()) + self.transactions.iter() } }